[dagster-airbyte] Implement get_job_details method in AirbyteCloudClient

dagster-io · Dec 17, 2024 · 29fc024 · 29fc024
1 parent 54820c2
commit 29fc024
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
@@ -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):