Evgeny Podlepaev created AIRFLOW-2774:
-----------------------------------------
Summary: DataFlowPythonOperator needs to support DirectRunner to
facilitate local testing
Key: AIRFLOW-2774
URL: https://issues.apache.org/jira/browse/AIRFLOW-2774
Project: Apache Airflow
Issue Type: Improvement
Components: Dataflow
Affects Versions: 1.9.0
Reporter: Evgeny Podlepaev
**DataFlowPythonOperator needs to support DirectRunner as a runner option to
facilitate local testing of the entire pipeline. Right now if DirectRunner is
set via job options, the DataFlowHook will wait infinitely trying to get status
of the remote job which does not exist:
_DataflowJob(self.get_conn(), variables['project'], name,
variables['region'], self.poll_sleep).wait_for_done()
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
