diff --git a/metadata-ingestion/src/datahub_provider/_lineage_core.py b/metadata-ingestion/src/datahub_provider/_lineage_core.py index fe15704553..05cadcbfca 100644 --- a/metadata-ingestion/src/datahub_provider/_lineage_core.py +++ b/metadata-ingestion/src/datahub_provider/_lineage_core.py @@ -1,7 +1,6 @@ import json from typing import TYPE_CHECKING, Dict, List -import dateutil.parser from airflow.configuration import conf import datahub.emitter.mce_builder as builder @@ -191,7 +190,6 @@ def send_lineage_to_datahub( } if config.capture_ownership_info: - timestamp = int(dateutil.parser.parse(context["ts"]).timestamp() * 1000) ownership = models.OwnershipClass( owners=[ models.OwnerClass( @@ -204,7 +202,7 @@ def send_lineage_to_datahub( ) ], lastModified=models.AuditStampClass( - time=timestamp, actor=builder.make_user_urn("airflow") + time=0, actor=builder.make_user_urn("airflow") ), ) # operator.log.info(f"{ownership=}")