[jira] [Resolved] (BEAM-4755) Cython cast error for Interactive Runner with FnAPI mode direct runner

["Qinye Li (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BEAM-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Qinye Li resolved BEAM-4755.
----------------------------
    Resolution: Fixed

> Cython cast error for Interactive Runner with FnAPI mode direct runner
> ----------------------------------------------------------------------
>
>                 Key: BEAM-4755
>                 URL: https://issues.apache.org/jira/browse/BEAM-4755
>             Project: Beam
>          Issue Type: Bug
>          Components: sdk-py-harness
>    Affects Versions: Not applicable
>         Environment: Linux
>            Reporter: Qinye Li
>            Assignee: Robert Bradshaw
>            Priority: Minor
>             Fix For: Not applicable
>
>
> When Interactive Runner uses FnAPI mode DirectRunner as the underlying runner,
> `cython.cast(Receiver, self.receivers[output_index])` in `Operation.output` throws an error that complains
>  
> File "/usr/local/home/qinyeli/beam/sdks/python/apache_beam/runners/worker/operations.py", line 178, in output
>  print(cython.cast(Receiver, self.receivers[output_index]))
>  File "/usr/local/home/qinyeli/.local/lib/python2.7/site-packages/Cython/Shadow.py", line 164, in cast
>  return type(*args)
> TypeError: object() takes no parameters
>  
> To replicate the error:
> Run a batch pipeline with interactive runner and explicitly specify to use direct_runner.SwitchingDirectRunner() as the underlying runner.
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)