yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-11-15 02:43:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(lineage backend): fix ownership timestamps (#3498)

Browse Source
This commit is contained in:
Gabe Lyons 2021-11-01 18:54:48 -07:00 committed by GitHub
parent dda2078dd7
commit 758631287b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
metadata-ingestion/src/datahub_provider/_lineage_core.py
View File

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