in sync/datahub/utils.py [0:0]
def get_current_timestamp() -> AuditStampClass: now = int(time.time() * 1000) # milliseconds since epoch return AuditStampClass(time=now, actor="urn:li:corpuser:ingestion")