mirror of
https://github.com/datahub-project/datahub.git
synced 2025-07-03 07:09:21 +00:00
13 lines
391 B
Python
13 lines
391 B
Python
|
from datahub.api.entities.datajob import DataFlow, DataJob
|
||
|
|
from datahub.emitter.rest_emitter import DatahubRestEmitter
|
||
|
|
|
||
|
|
# Create an emitter to the GMS REST API.
|
||
|
|
|
||
|
|
emitter = DatahubRestEmitter("http://localhost:8080")
|
||
|
|
|
||
|
|
jobFlow = DataFlow(cluster="prod", orchestrator="airflow", id="flow_new_api")
|
||
|
|
jobFlow.emit(emitter)
|
||
|
|
|
||
|
|
dataJob = DataJob(flow_urn=jobFlow.urn, id="job1")
|
||
|
|
dataJob.emit(emitter)
|