It appears to be broken and there is a known issue : https://github.com/apache/beam/issues/19851 .
On Fri, Mar 8, 2024 at 8:40 AM Joey Tran <joey.t...@schrodinger.com> wrote: > In the python SDK, should we be able to supply side inputs to > CombineGlobally? > > I created an example here that fails at the pipeline translation stage > https://play.beam.apache.org/?sdk=python&shared=vjM_k2TvNrf > > It fails with > ``` > File > "/Users/jtran/builds/2024-2/build/internal/lib/python3.11/site-packages/apache_beam/runners/portability/fn_api_runner/translations.py", > line 1367, in lift_combiners > expansion = lifted_stages if can_lift(transform) else unlifted_stages > ^^^^^^^^^^^^^^^^^^^ > File > "/Users/jtran/builds/2024-2/build/internal/lib/python3.11/site-packages/apache_beam/runners/portability/fn_api_runner/translations.py", > line 1239, in can_lift > context.components.pcollections[only_element( > ^^^^^^^^^^^^^ > File > "/Users/jtran/builds/2024-2/build/internal/lib/python3.11/site-packages/apache_beam/runners/portability/fn_api_runner/translations.py", > line 2082, in only_element > element, = iterable > ^^^^^^^^ > ValueError: too many values to unpack (expected 1) > ``` >
