Skip to content

Commit efad2f7

Browse files
committed
revert outputs
1 parent 99f77d1 commit efad2f7

File tree

2 files changed

+11
-3
lines changed

2 files changed

+11
-3
lines changed

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

+6-1
Original file line numberDiff line numberDiff line change
@@ -397,7 +397,12 @@ def _get_run_workunits(
397397
model_version_urn = self._make_ml_model_urn(model_versions[0])
398398
yield MetadataChangeProposalWrapper(
399399
entityUrn=str(data_process_instance.urn),
400-
aspect=DataProcessInstanceOutputClass(outputs=[model_version_urn]),
400+
aspect=DataProcessInstanceOutputClass(
401+
outputs=[],
402+
outputEdges=[
403+
EdgeClass(destinationUrn=model_version_urn),
404+
],
405+
),
401406
).as_workunit()
402407

403408
metrics = self._get_run_metrics(run)

metadata-ingestion/tests/integration/mlflow/mlflow_mcps_golden.json

+5-2
Original file line numberDiff line numberDiff line change
@@ -308,8 +308,11 @@
308308
"aspectName": "dataProcessInstanceOutput",
309309
"aspect": {
310310
"json": {
311-
"outputs": [
312-
"urn:li:mlModel:(urn:li:dataPlatform:mlflow,test-model_1,PROD)"
311+
"outputs": [],
312+
"outputEdges": [
313+
{
314+
"destinationUrn": "urn:li:mlModel:(urn:li:dataPlatform:mlflow,test-model_1,PROD)"
315+
}
313316
]
314317
}
315318
},

0 commit comments

Comments
 (0)