[
https://issues.apache.org/jira/browse/BEAM-5507?focusedWorklogId=148531&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-148531
]
ASF GitHub Bot logged work on BEAM-5507:
----------------------------------------
Author: ASF GitHub Bot
Created on: 27/Sep/18 00:02
Start Date: 27/Sep/18 00:02
Worklog Time Spent: 10m
Work Description: aaltay closed pull request #6477: [BEAM-5507] Pass
--pubsubRooturl option to Dataflow runner.
URL: https://github.com/apache/beam/pull/6477
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/sdks/python/apache_beam/options/pipeline_options.py
b/sdks/python/apache_beam/options/pipeline_options.py
index 7da91a668da..7bb3bc9a0ba 100644
--- a/sdks/python/apache_beam/options/pipeline_options.py
+++ b/sdks/python/apache_beam/options/pipeline_options.py
@@ -710,6 +710,20 @@ def validate(self, validator):
errors.extend(validator.validate_test_matcher(self,
'on_success_matcher'))
return errors
+
+class TestDataflowOptions(PipelineOptions):
+
+ @classmethod
+ def _add_argparse_args(cls, parser):
+ # This option is passed to Dataflow Runner's Pub/Sub client. The camelCase
+ # style in 'dest' matches the runner's.
+ parser.add_argument(
+ '--pubsub_root_url',
+ dest='pubsubRootUrl',
+ default=None,
+ help='Root URL for use with the Google Cloud Pub/Sub API.',)
+
+
# TODO(silviuc): Add --files_to_stage option.
# This could potentially replace the --requirements_file and --setup_file.
----------------------------------------------------------------
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: 148531)
Time Spent: 40m (was: 0.5h)
> Pass pubsubRootUrl option to Dataflow runner.
> ---------------------------------------------
>
> Key: BEAM-5507
> URL: https://issues.apache.org/jira/browse/BEAM-5507
> Project: Beam
> Issue Type: Bug
> Components: sdk-py-core
> Reporter: Udi Meiri
> Assignee: Udi Meiri
> Priority: Major
> Time Spent: 40m
> Remaining Estimate: 0h
>
> This option will be used for testing only.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
