From 29fc024a008e9375184dfe86c62283f564f85919 Mon Sep 17 00:00:00 2001 From: Maxime Armstrong Date: Thu, 12 Dec 2024 00:01:39 -0500 Subject: [PATCH] [dagster-airbyte] Implement get_job_details 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 2be0677807f1b..a926e6d8962c1 100644 --- a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py +++ b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py @@ -1003,6 +1003,9 @@ def start_sync_job(self, connection_id: str) -> Mapping[str, Any]: }, ) + def get_job_details(self, job_id: int) -> Mapping[str, Any]: + return self._make_request(method="GET", endpoint=f"jobs/{job_id}", base_url=self.rest_api_base_url) + @experimental class AirbyteCloudWorkspace(ConfigurableResource):