This is an automated email from the ASF dual-hosted git repository.
pabloem 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 d52d92f Fix formatting
new 860131b Merge pull request #10981 from pabloem/fxfrmt
d52d92f is described below
commit d52d92f5640b4a310509500816c2bbad292931ba
Author: pabloem <[email protected]>
AuthorDate: Wed Feb 26 16:23:53 2020 -0800
Fix formatting
---
sdks/python/apache_beam/runners/dataflow/test_dataflow_runner.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/sdks/python/apache_beam/runners/dataflow/test_dataflow_runner.py
b/sdks/python/apache_beam/runners/dataflow/test_dataflow_runner.py
index 720526f..43bc32c 100644
--- a/sdks/python/apache_beam/runners/dataflow/test_dataflow_runner.py
+++ b/sdks/python/apache_beam/runners/dataflow/test_dataflow_runner.py
@@ -83,8 +83,8 @@ class TestDataflowRunner(DataflowRunner):
region_id = options.view_as(GoogleCloudOptions).region
job_id = self.result.job_id()
return (
- 'https://console.cloud.google.com/dataflow/jobs/%s/%s?project=%s'
- % (region_id, job_id, project))
+ 'https://console.cloud.google.com/dataflow/jobs/%s/%s?project=%s' %
+ (region_id, job_id, project))
def wait_until_in_state(self, expected_state, timeout=WAIT_IN_STATE_TIMEOUT):
"""Wait until Dataflow pipeline enters a certain state."""
