Re: [PR] Add DatabricksTaskOperator [airflow]

pankajkoti merged PR #40013: URL: https://github.com/apache/airflow/pull/40013 -- 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: commits-unsubscr...@airfl

Re: [PR] Add DatabricksTaskOperator [airflow]

pankajkoti commented on code in PR #40013: URL: https://github.com/apache/airflow/pull/40013#discussion_r1625730872 ## docs/apache-airflow-providers-databricks/operators/task.rst: ## @@ -0,0 +1,44 @@ + .. Licensed to the Apache Software Foundation (ASF) under one +or more co

Re: [PR] Add DatabricksTaskOperator [airflow]

tatiana commented on code in PR #40013: URL: https://github.com/apache/airflow/pull/40013#discussion_r1625700187 ## docs/apache-airflow-providers-databricks/operators/task.rst: ## @@ -0,0 +1,44 @@ + .. Licensed to the Apache Software Foundation (ASF) under one +or more contr

Re: [PR] Add DatabricksTaskOperator [airflow]

pankajkoti commented on code in PR #40013: URL: https://github.com/apache/airflow/pull/40013#discussion_r1624231989 ## tests/system/providers/databricks/example_databricks.py: ## @@ -201,6 +202,39 @@ ) # [END howto_operator_databricks_notebook_existing_cluster] +

Re: [PR] Add DatabricksTaskOperator [airflow]

pankajkoti commented on code in PR #40013: URL: https://github.com/apache/airflow/pull/40013#discussion_r1624218899 ## airflow/providers/databricks/operators/databricks.py: ## @@ -1136,28 +1032,71 @@ def _handle_terminal_run_state(self, run_state: RunState) -> None:

Re: [PR] Add DatabricksTaskOperator [airflow]

pankajkoti commented on code in PR #40013: URL: https://github.com/apache/airflow/pull/40013#discussion_r1624218559 ## airflow/providers/databricks/operators/databricks.py: ## @@ -1118,14 +1012,16 @@ def _get_run_json(self) -> dict[str, Any]: raise ValueError("Must

Re: [PR] Add DatabricksTaskOperator [airflow]

pankajkoti commented on code in PR #40013: URL: https://github.com/apache/airflow/pull/40013#discussion_r1624218143 ## airflow/providers/databricks/operators/databricks.py: ## @@ -1178,10 +1118,250 @@ def execute(self, context: Context) -> None: self.databricks_run_

Re: [PR] Add DatabricksTaskOperator [airflow]

Lee-W commented on code in PR #40013: URL: https://github.com/apache/airflow/pull/40013#discussion_r1624168208 ## tests/system/providers/databricks/example_databricks.py: ## @@ -201,6 +202,39 @@ ) # [END howto_operator_databricks_notebook_existing_cluster] +# [ST

Re: [PR] Add DatabricksTaskOperator [airflow]

pankajastro commented on code in PR #40013: URL: https://github.com/apache/airflow/pull/40013#discussion_r1624117127 ## airflow/providers/databricks/operators/databricks.py: ## @@ -1178,10 +1118,250 @@ def execute(self, context: Context) -> None: self.databricks_run

Re: [PR] Add DatabricksTaskOperator [airflow]

pankajastro commented on code in PR #40013: URL: https://github.com/apache/airflow/pull/40013#discussion_r1624123727 ## airflow/providers/databricks/operators/databricks.py: ## @@ -1118,14 +1012,16 @@ def _get_run_json(self) -> dict[str, Any]: raise ValueError("Must

Re: [PR] Add DatabricksTaskOperator [airflow]

pankajkoti commented on code in PR #40013: URL: https://github.com/apache/airflow/pull/40013#discussion_r1624123821 ## tests/system/providers/databricks/example_databricks.py: ## @@ -201,6 +202,39 @@ ) # [END howto_operator_databricks_notebook_existing_cluster] +

Re: [PR] Add DatabricksTaskOperator [airflow]

Lee-W commented on code in PR #40013: URL: https://github.com/apache/airflow/pull/40013#discussion_r1624067400 ## airflow/providers/databricks/operators/databricks.py: ## @@ -1136,28 +1032,71 @@ def _handle_terminal_run_state(self, run_state: RunState) -> None: )

Re: [PR] Add DatabricksTaskOperator [airflow]

pankajkoti commented on PR #40013: URL: https://github.com/apache/airflow/pull/40013#issuecomment-2144382409 cc: @tatiana for helping review the PR. -- 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 t

[PR] Add DatabricksTaskOperator [airflow]

pankajkoti opened a new pull request, #40013: URL: https://github.com/apache/airflow/pull/40013 --- **^ Add meaningful description above** Read the **[Pull Request Guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst