mirror of
https://github.com/datahub-project/datahub.git
synced 2025-06-27 05:03:31 +00:00
35a4434490
Co-authored-by: mohdsiddique <mohdsiddiquebagwan@gmail.com> Co-authored-by: Harshal Sheth <hsheth2@gmail.com>
13 lines
387 B
Python
13 lines
387 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(env="prod", orchestrator="airflow", id="flow_new_api")
|
|
jobFlow.emit(emitter)
|
|
|
|
dataJob = DataJob(flow_urn=jobFlow.urn, id="job1")
|
|
dataJob.emit(emitter)
|