Use dynamic returns for ray_execute_bundle

ray-project / ray_beam_runner

Ray-based Apache Beam runner

Apache License 2.0

41 stars 12 forks source link

Closed jjyao closed 1 year ago

jjyao commented 1 year ago

Signed-off-by: Jiajun Yao jeromeyjj@gmail.com

With dynamic returns feature, we no longer need to calculate the number of returns beforehand.

jjyao commented 1 year ago

GH has some issue right now so CI is not triggered. Don't merge it until I run all tests.

pabloem commented 1 year ago

this is awesome. Thanks LGTM!