Can we explicitly pass the parameters: `hook` and `log`, into this function and 
lift the logic to initially invoke `run-now` or `run-submit` back into the 
operator? The end result would be a helper function responsible for polling for 
the run result.

With this solution, we'd duplicate a bit of logic with the xcom business (which 
we can refactor later) but we avoid having to pass the wide interface of an 
`operator` (which is really a special databricks operato) to this function.

[ Full content available at: 
https://github.com/apache/incubator-airflow/pull/3813 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to