[
https://issues.apache.org/jira/browse/BEAM-588?focusedWorklogId=165416&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-165416
]
ASF GitHub Bot logged work on BEAM-588:
---------------------------------------
Author: ASF GitHub Bot
Created on: 13/Nov/18 13:11
Start Date: 13/Nov/18 13:11
Worklog Time Spent: 10m
Work Description: robertwb commented on a change in pull request #6847:
[BEAM-588] Implement profiling for Python DirectRunner and SDK Harness.
URL: https://github.com/apache/beam/pull/6847#discussion_r232677511
##########
File path: sdks/python/apache_beam/runners/portability/fn_api_runner.py
##########
@@ -235,11 +241,54 @@ def run_pipeline(self, pipeline):
# are known to be KVs.
from apache_beam.runners.dataflow.dataflow_runner import DataflowRunner
pipeline.visit(DataflowRunner.group_by_key_input_visitor())
+ self._bundle_repeat = self._bundle_repeat or pipeline._options.view_as(
Review comment:
No, runners don't have another way of accessing options (yet?).
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 165416)
Time Spent: 20m (was: 10m)
> All runners should support ProfilingOptions
> -------------------------------------------
>
> Key: BEAM-588
> URL: https://issues.apache.org/jira/browse/BEAM-588
> Project: Beam
> Issue Type: Improvement
> Components: sdk-py-core
> Reporter: Ahmet Altay
> Priority: Minor
> Labels: newbie, starter
> Time Spent: 20m
> Remaining Estimate: 0h
>
> https://github.com/apache/incubator-beam/blob/python-sdk/sdks/python/apache_beam/utils/options.py#L366
> This is useful for profiling pipelines in different environments.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
