ha2hi commented on code in PR #64766:
URL: https://github.com/apache/airflow/pull/64766#discussion_r3147400755
##########
providers/databricks/src/airflow/providers/databricks/hooks/databricks.py:
##########
@@ -302,6 +303,14 @@ def create_job(self, json: dict) -> int:
response = self._do_api_call(CREATE_ENDPOINT, json)
return response["job_id"]
+ def delete_job(self, job_id: int) -> None:
+ """
+ Call the ``api/2.2/jobs/delete`` endpoint.
+
+ :param job_id: The unique identifier of the job to be deleted.
+ """
+ self._do_api_call(DELETE_ENDPOINT, {"job_id": job_id})
Review Comment:
I've updated the signature to accept str | int for consistency with other
methods and added explicit coercion to int before the API call to ensure the
payload type is correct.
--
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]
