You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2020/09/09 17:10:45 UTC
[beam] branch master updated: Fix Python formatting on master branch
This is an automated email from the ASF dual-hosted git repository.
altay 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 a3d947c Fix Python formatting on master branch
new 6213d47 Merge pull request #12795 from kamilwu/fix-formatting
a3d947c is described below
commit a3d947cbc84eb8fdea76f7d66e4497e40ed9326a
Author: Kamil Wasilewski <ka...@polidea.com>
AuthorDate: Wed Sep 9 17:36:08 2020 +0200
Fix Python formatting on master branch
---
sdks/python/apache_beam/runners/dataflow/internal/apiclient.py | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
index 47dcc78..7d9eb21 100644
--- a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
+++ b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
@@ -923,9 +923,10 @@ class DataflowApplicationClient(object):
pageToken=token)
response = self._client.projects_locations_jobs.List(request)
for job in response.jobs:
- if (job.name == job_name and job.currentState in
- [dataflow.Job.CurrentStateValueValuesEnum.JOB_STATE_RUNNING,
- dataflow.Job.CurrentStateValueValuesEnum.JOB_STATE_DRAINING]):
+ if (job.name == job_name and job.currentState in [
+ dataflow.Job.CurrentStateValueValuesEnum.JOB_STATE_RUNNING,
+ dataflow.Job.CurrentStateValueValuesEnum.JOB_STATE_DRAINING
+ ]):
return job.id
token = response.nextPageToken
if token is None: