File tree 2 files changed +7
-7
lines changed
sdks/python/apache_beam/runners
2 files changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -567,9 +567,10 @@ def invoke_process(self,
567
567
additional_args = None ,
568
568
additional_kwargs = None
569
569
):
570
- # type: (...) -> None
570
+ # type: (...) -> Iterable[SplitResultResidual]
571
571
self .output_processor .process_outputs (
572
572
windowed_value , self .process_method (windowed_value .value ))
573
+ return []
573
574
574
575
575
576
class PerWindowInvoker (DoFnInvoker ):
Original file line number Diff line number Diff line change @@ -710,13 +710,12 @@ def start(self):
710
710
def process (self , o ):
711
711
# type: (WindowedValue) -> None
712
712
with self .scoped_process_state :
713
- delayed_application = self .dofn_runner .process (o )
714
- if delayed_application :
713
+ delayed_applications = self .dofn_runner .process (o )
714
+ if delayed_applications :
715
715
assert self .execution_context is not None
716
- # TODO(BEAM-77746): there's disagreement between subclasses
717
- # of DoFnRunner over the return type annotations of process().
718
- self .execution_context .delayed_applications .append (
719
- (self , delayed_application )) # type: ignore[arg-type]
716
+ for delayed_application in delayed_applications :
717
+ self .execution_context .delayed_applications .append (
718
+ (self , delayed_application ))
720
719
721
720
def finalize_bundle (self ):
722
721
# type: () -> None
You can’t perform that action at this time.
0 commit comments