-
Notifications
You must be signed in to change notification settings - Fork 3.2k
feat(ingest): update mlflow connector with new sdk v2 #13857
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: master
Are you sure you want to change the base?
feat(ingest): update mlflow connector with new sdk v2 #13857
Conversation
Bundle ReportChanges will increase total bundle size by 77 bytes (0.0%) ⬆️. This is within the configured threshold ✅ Detailed changes
Affected Assets, Files, and Routes:view changes for bundle: datahub-react-web-esmAssets Changed:
|
Codecov ReportAll modified and coverable lines are covered by tests ✅ 📢 Thoughts on this report? Let us know! |
@@ -789,34 +743,36 @@ def _get_ml_model_properties_workunit( | |||
training_metrics = None | |||
training_jobs = [] | |||
|
|||
created_time = model_version.creation_timestamp | |||
created_actor = ( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
we probably need to add this to the mlmodel entity
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
let's make sure there's no behavior changes
metadata-ingestion/tests/integration/mlflow/mlflow_mcps_golden.json
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
update golden file diff checker ignore rules
@@ -699,13 +713,12 @@ def _get_mlflow_run(self, model_version: ModelVersion) -> Union[None, Run]: | |||
else: | |||
return None | |||
|
|||
def _get_ml_model_workunits(self) -> Iterable[MetadataWorkUnit]: | |||
def _get_ml_model_workunits(self) -> Iterable[Union[MetadataWorkUnit, Entity]]: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why does this still need MetadataWorkUnit?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yield self._get_global_tags_workunit(model_version=model_version)
this still returns MetadataWorkUnit
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Having trouble reading through the diff here. Are there any important changes that we need to look at here?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
i pushed one fix for tags -- we don't really use HasTag for mlmodel "tags" -- we just push them to mlmodelproperties.tags
model_group=ml_model_group_urn, | ||
training_jobs=training_jobs, | ||
extra_aspects=[MLModelPropertiesClass(tags=model_version_tags)], |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
what were the results of your investigation? where is the right spot to put tags?
imo our MLModel
should handle any discrepancies by overriding the methods from HasTags. The user should not need to deal with these details. In other words - this feels like a bug in our MLModel sdk
@yoonhyejin looks like lint is failing |
No description provided.