This is an automated email from the ASF dual-hosted git repository.
ibzib pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 5b43602 [BEAM-7924] fix options attribute error
new bb278f4 Merge pull request #9365 from ibzib/py-opts
5b43602 is described below
commit 5b43602109648830522159221a283754ed959afa
Author: Kyle Weaver <[email protected]>
AuthorDate: Fri Aug 16 14:35:55 2019 -0700
[BEAM-7924] fix options attribute error
---
sdks/python/apache_beam/runners/worker/sdk_worker_main.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
b/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
index 81bc1b5..f28703e 100644
--- a/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
+++ b/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
@@ -31,9 +31,9 @@ from builtins import object
from google.protobuf import text_format
from apache_beam.internal import pickler
-from apache_beam.options import pipeline_options
from apache_beam.options.pipeline_options import DebugOptions
from apache_beam.options.pipeline_options import PipelineOptions
+from apache_beam.options.pipeline_options import ProfilingOptions
from apache_beam.portability.api import endpoints_pb2
from apache_beam.runners.internal import names
from apache_beam.runners.worker.log_handler import FnApiLogRecordHandler
@@ -150,7 +150,7 @@ def main(unused_argv):
worker_count=_get_worker_count(sdk_pipeline_options),
worker_id=_worker_id,
profiler_factory=profiler.Profile.factory_from_options(
- sdk_pipeline_options.view_as(pipeline_options.ProfilingOptions))
+ sdk_pipeline_options.view_as(ProfilingOptions))
).run()
logging.info('Python sdk harness exiting.')
except: # pylint: disable=broad-except
