Skip to content

Commit ea885e6

Browse files
committed
update dpi to use Edges
1 parent 95205a0 commit ea885e6

File tree

1 file changed

+7
-1
lines changed
  • metadata-ingestion/src/datahub/ingestion/source

1 file changed

+7
-1
lines changed

metadata-ingestion/src/datahub/ingestion/source/mlflow.py

+7-1
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@
4747
DataProcessInstanceRunEventClass,
4848
DataProcessInstanceRunResultClass,
4949
DataProcessRunStatusClass,
50+
EdgeClass,
5051
GlobalTagsClass,
5152
MetadataAttributionClass,
5253
MLHyperParamClass,
@@ -312,7 +313,12 @@ def _get_run_workunits(
312313
model_version_urn = self._make_ml_model_urn(model_versions[0])
313314
yield MetadataChangeProposalWrapper(
314315
entityUrn=str(data_process_instance.urn),
315-
aspect=DataProcessInstanceOutputClass(outputs=[model_version_urn]),
316+
aspect=DataProcessInstanceOutputClass(
317+
outputs=[],
318+
outputEdges=[
319+
EdgeClass(destinationUrn=model_version_urn),
320+
],
321+
),
316322
).as_workunit()
317323

318324
metrics = self._get_run_metrics(run)

0 commit comments

Comments
 (0)