alexott commented on code in PR #25623:
URL: https://github.com/apache/airflow/pull/25623#discussion_r941598917
##########
airflow/providers/databricks/operators/databricks.py:
##########
@@ -333,6 +341,8 @@ def __init__(
self.json['spark_submit_task'] = spark_submit_task
if pipeline_task is not None:
self.json['pipeline_task'] = pipeline_task
+ if dbt_task is not None:
+ self.json['dbt_task'] = dbt_task
Review Comment:
If the git source is required, I would move this code after this line
https://github.com/apache/airflow/pull/25623/files#diff-30731826b25d422cb6069898701e34f8ef23b2a32b7782444793a14bc52b0cb1L352
and throw exception if it isn’t set - this will allow to catch
misconfigurations early…
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
