From 01c67e04cecccaecebe5a8fe3a28edf4f16cf019 Mon Sep 17 00:00:00 2001 From: Maxime Armstrong Date: Thu, 12 Dec 2024 00:10:32 -0500 Subject: [PATCH] [dagster-airbyte] Implement cancel_job method in AirbyteCloudClient --- .../libraries/dagster-airbyte/dagster_airbyte/resources.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py index 02f483833aeb1..7daf470948a46 100644 --- a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py +++ b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py @@ -1008,6 +1008,9 @@ def get_job_details(self, job_id: int) -> Mapping[str, Any]: method="GET", endpoint=f"jobs/{job_id}", base_url=self.rest_api_base_url ) + def cancel_job(self, job_id: int) -> Mapping[str, Any]: + return self.make_request(method="DELETE", endpoint=f"jobs/{job_id}") + @experimental class AirbyteCloudWorkspace(ConfigurableResource):