This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new dc47c460dc Update docs in databricks.py - we use 2.1 now (#32340)
dc47c460dc is described below
commit dc47c460dc0edfbfe0e692eac1d07b42280e0810
Author: Stas Bytsko <[email protected]>
AuthorDate: Thu Aug 24 12:50:18 2023 +0300
Update docs in databricks.py - we use 2.1 now (#32340)
---
airflow/providers/databricks/hooks/databricks.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow/providers/databricks/hooks/databricks.py
b/airflow/providers/databricks/hooks/databricks.py
index e880a42eee..64ac9b341d 100644
--- a/airflow/providers/databricks/hooks/databricks.py
+++ b/airflow/providers/databricks/hooks/databricks.py
@@ -137,7 +137,7 @@ class DatabricksHook(BaseDatabricksHook):
def run_now(self, json: dict) -> int:
"""
- Utility function to call the ``api/2.0/jobs/run-now`` endpoint.
+ Utility function to call the ``api/2.1/jobs/run-now`` endpoint.
:param json: The data used in the body of the request to the
``run-now`` endpoint.
:return: the run_id as an int
@@ -147,7 +147,7 @@ class DatabricksHook(BaseDatabricksHook):
def submit_run(self, json: dict) -> int:
"""
- Utility function to call the ``api/2.0/jobs/runs/submit`` endpoint.
+ Utility function to call the ``api/2.1/jobs/runs/submit`` endpoint.
:param json: The data used in the body of the request to the
``submit`` endpoint.
:return: the run_id as an int