[dagster-airbyte] Implement base sync method in AirbyteCloudClient

dagster-io · Dec 12, 2024 · a831f47 · a831f47
1 parent 65751c7
commit a831f47
Showing 1 changed file with 10 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
@@ -992,6 +992,16 @@ def get_destination_details(self, destination_id: str) -> Mapping[str, Any]:
             base_url=self.rest_api_base_url,
         )
 
+    def start_sync_job(self, connection_id: str) -> Mapping[str, Any]:
+        return self._make_request(
+                endpoint="jobs",
+                data={
+                    "connectionId": connection_id,
+                    "jobType": "sync",
+                },
+            )
+
+
 
 @experimental
 class AirbyteCloudWorkspace(ConfigurableResource):