fix(ingest/starburst): parse create_time datetime format (#10345)

datahub-project · Apr 22, 2024 · 725c858 · 725c858
1 parent 8d90c21
commit 725c858
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/metadata-ingestion/src/datahub/ingestion/source/usage/starburst_trino_usage.py b/metadata-ingestion/src/datahub/ingestion/source/usage/starburst_trino_usage.py
@@ -191,6 +191,8 @@ def _convert_str_to_datetime(self, v):
  if isinstance(v, str):
  isodate = parser.parse(v) # compatible with Python 3.6+
  return isodate
+ if isinstance(v, datetime):
+ return v
 
  def _get_joined_access_event(self, events):
  joined_access_events = []