Skip to content

Commit 6740d94

Browse files
committed
Update fivetran_api_client.py
1 parent 8f1013a commit 6740d94

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

metadata-ingestion/src/datahub/ingestion/source/fivetran/fivetran_api_client.py

+1-3
Original file line numberDiff line numberDiff line change
@@ -201,14 +201,12 @@ def _enrich_bigquery_connector(
201201

202202
def list_connector_schemas(self, connector_id: str) -> List[Dict]:
203203
"""Get schema information for a connector."""
204-
# Check cache first
205204
if connector_id in self._schema_cache:
206205
return self._schema_cache[connector_id]
207206

208207
response = self._make_request("GET", f"/connectors/{connector_id}/schemas")
209208
schemas = response.get("data", {}).get("schemas", [])
210209

211-
# Cache the response
212210
self._schema_cache[connector_id] = schemas
213211
return schemas
214212

@@ -335,7 +333,7 @@ def list_connector_sync_history(
335333
# Try v1/connectors/{connector_id}/logs (most likely endpoint)
336334
try:
337335
response = self._make_request(
338-
"GET", f"/connectors/{connector_id}/logs", params=params
336+
"GET", f"/connectors/{connector_id}/sync-history", params=params
339337
)
340338
logs = response.get("data", {}).get("items", [])
341339
if logs:

0 commit comments

Comments
 (0)