We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
The Ray Runner does not support accessing state by ParDo / DoFns. This test verifies this behavior:
https://github.com/ray-project/ray_beam_runner/blob/master/ray_beam_runner/portability/ray_runner_test.py#L328-L352
We have an implementation of a state manager (https://github.com/ray-project/ray_beam_runner/blob/master/ray_beam_runner/portability/execution.py#L205-L243), as an Actor that implements the state servicer interface (https://github.com/apache/beam/blob/044313637c9eea2e3c2b0baa60bc853a948c12ee/sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py#L944). We need to verify that the state is plumbed through and working.
The text was updated successfully, but these errors were encountered:
enable dofn state support
ba8f230
Fixes ray-project#12
615e351
enable dofn state support (#27)
45cf717
Fixes #12
iasoon
Successfully merging a pull request may close this issue.
The Ray Runner does not support accessing state by ParDo / DoFns. This test verifies this behavior:
https://github.com/ray-project/ray_beam_runner/blob/master/ray_beam_runner/portability/ray_runner_test.py#L328-L352
We have an implementation of a state manager (https://github.com/ray-project/ray_beam_runner/blob/master/ray_beam_runner/portability/execution.py#L205-L243), as an Actor that implements the state servicer interface (https://github.com/apache/beam/blob/044313637c9eea2e3c2b0baa60bc853a948c12ee/sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py#L944). We need to verify that the state is plumbed through and working.
The text was updated successfully, but these errors were encountered: