[
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)
