Add persistence of side inputs into state after they are calculated / executed

Question

Closed this issue 2 years ago · 2 comments

Side inputs are not supported at the moment. To test support, we only need to enable this test:

The code exists to support this (https://github.com/ray-project/ray_beam_runner/blob/master/ray_beam_runner/portability/ray_fn_runner.py#L455-L459), but we need to figure out how the protocol to write and access side input state.

We need first to support state (issue #12 ) and then implement this.

Answer 1 · 2022-06-14T17:58:32.000Z

Answer 2 · 2022-10-26T16:22:05.000Z

this was implemented in #44 with @iasoon implementation plus some fixes to data races