shunping commented on code in PR #34775:
URL: https://github.com/apache/beam/pull/34775#discussion_r2066362826
##########
sdks/python/apache_beam/pipeline.py:
##########
@@ -173,8 +173,13 @@ def __init__(
if options is not None:
if isinstance(options, PipelineOptions):
# Make a deep copy of options since they could be overwritten in later
- # steps.
+ # steps. However, the 'runner' object within 'options' is excluded from
+ # the deep copy (it is shallow copied) due to potential issues with
deep
+ # copying specific runner instances, such as FlumeRunner.
+ saved_runner = options.view_as(StandardOptions).runner
+ options.view_as(StandardOptions).runner = None
Review Comment:
Done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@beam.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
