Fix start_sync_job

dagster-io · Dec 12, 2024 · dd9a37d · dd9a37d
1 parent a831f47
commit dd9a37d
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py
@@ -994,13 +994,14 @@ def get_destination_details(self, destination_id: str) -> Mapping[str, Any]:
 
     def start_sync_job(self, connection_id: str) -> Mapping[str, Any]:
         return self._make_request(
-                endpoint="jobs",
-                data={
-                    "connectionId": connection_id,
-                    "jobType": "sync",
-                },
-            )
-
+            method="POST",
+            endpoint="jobs",
+            base_url=self.rest_api_base_url,
+            data={
+                "connectionId": connection_id,
+                "jobType": "sync",
+            },
+        )
 
 
 @experimental