mirror of
https://github.com/datahub-project/datahub.git
synced 2025-07-04 07:34:44 +00:00
14 lines
357 B
Python
14 lines
357 B
Python
|
from datahub.metadata.urns import TagUrn
|
||
|
|
from datahub.sdk import DataFlow, DataHubClient
|
||
|
|
|
||
|
|
client = DataHubClient.from_env()
|
||
|
|
|
||
|
|
dataflow = DataFlow(
|
||
|
|
name="example_dataflow",
|
||
|
|
platform="airflow",
|
||
|
|
description="airflow pipeline for production",
|
||
|
|
tags=[TagUrn(name="production"), TagUrn(name="data_engineering")],
|
||
|
|
)
|
||
|
|
|
||
|
|
client.entities.upsert(dataflow)
|