mirror of
https://github.com/datahub-project/datahub.git
synced 2025-07-04 07:34:44 +00:00
eda1db081b
Co-authored-by: John Joyce <john@Johns-MacBook-Pro.local> Co-authored-by: John Joyce <john@ip-10-0-0-48.us-west-2.compute.internal> Co-authored-by: John Joyce <john@Johns-MBP-432.lan> Co-authored-by: John Joyce <john@ip-192-168-1-200.us-west-2.compute.internal> Co-authored-by: John Joyce <john@Johns-MBP.lan>
20 lines
579 B
Python
20 lines
579 B
Python
from datahub.api.graphql import Operation
|
|
|
|
DATAHUB_HOST = "https//:org.acryl.io/gms"
|
|
DATAHUB_TOKEN = "<your-datahub-access-token"
|
|
|
|
dataset_urn = "urn:li:dataset:(urn:li:dataPlatform:hive,fct_users_created,PROD)"
|
|
|
|
operation_client = Operation(
|
|
datahub_host=DATAHUB_HOST,
|
|
datahub_token=DATAHUB_TOKEN,
|
|
)
|
|
|
|
operation_type = "INSERT"
|
|
source_type = "DATA_PROCESS" # Source of the operation (data platform or DAG task)
|
|
|
|
# Report a change operation for the Dataset.
|
|
operation_client.report_operation(
|
|
urn=dataset_urn, operation_type=operation_type, source_type=source_type
|
|
)
|