Skip to content

Commit

Permalink
Fix mispositioned producer_type_hints and producer_batch_converter pa…
Browse files Browse the repository at this point in the history
…rams. (apache#24511)
  • Loading branch information
tvalentyn authored and lostluck committed Dec 22, 2022
1 parent 63b2eba commit 77b8830
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions sdks/python/apache_beam/runners/worker/bundle_processor.py
Original file line number Diff line number Diff line change
Expand Up @@ -195,13 +195,13 @@ def setup(self):
# We must do this manually as we don't have a spec or spec.output_coders.
self.receivers = [
operations.ConsumerSet.create(
self.counter_factory,
self.name_context.step_name,
0,
self.consumer,
self.windowed_coder,
self.get_output_batch_converter(),
self._get_runtime_performance_hints())
counter_factory=self.counter_factory,
step_name=self.name_context.step_name,
output_index=0,
consumers=self.consumer,
coder=self.windowed_coder,
producer_type_hints=self._get_runtime_performance_hints(),
producer_batch_converter=self.get_output_batch_converter())
]

def start(self):
Expand Down

0 comments on commit 77b8830

Please sign in to comment.