[AIRFLOW-5713] Remove dead code (#6382)
This commit is contained in:
Родитель
417754a14a
Коммит
b43922161a
|
@ -143,7 +143,6 @@ class _DataflowJobsController(LoggingMixin):
|
||||||
|
|
||||||
for job in self._jobs:
|
for job in self._jobs:
|
||||||
if job and 'currentState' in job:
|
if job and 'currentState' in job:
|
||||||
self._job_state = job['currentState']
|
|
||||||
self.log.info(
|
self.log.info(
|
||||||
'Google Cloud DataFlow job %s is %s',
|
'Google Cloud DataFlow job %s is %s',
|
||||||
job['name'], job['currentState']
|
job['name'], job['currentState']
|
||||||
|
|
Загрузка…
Ссылка в новой задаче