From dd9a37dd4fae4c1bd7ba8961b9947a44ef9a168a Mon Sep 17 00:00:00 2001 From: Maxime Armstrong Date: Thu, 12 Dec 2024 00:02:45 -0500 Subject: [PATCH] Fix start_sync_job --- .../dagster-airbyte/dagster_airbyte/resources.py | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py index 784b2b3971fd0..2be0677807f1b 100644 --- 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