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

Reply via email to