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):