[dagster-airbyte] Implement cancel_job method in AirbyteCloudClient

dagster-io · Dec 12, 2024 · 01c67e0 · 01c67e0
1 parent 00bdc9d
commit 01c67e0
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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):