@@ -507,12 +507,12 @@ def create_job(self, model: CreateJob) -> str:
507
507
if model .job_definition_id and model .mlflow_experiment_id :
508
508
experiment_id = model .mlflow_experiment_id
509
509
else :
510
- experiment_id = mlflow_client .create_experiment (f"{ model .name } -{ uuid4 ()} " )
510
+ experiment_id = mlflow_client .create_experiment (f"{ model .input_filename } -{ uuid4 ()} " )
511
511
model .mlflow_experiment_id = experiment_id
512
512
input_file_path = os .path .join (self .root_dir , model .input_uri )
513
513
mlflow .log_artifact (input_file_path , "input" )
514
514
515
- mlflow_run = mlflow_client .create_run (experiment_id = experiment_id , run_name = model .name )
515
+ mlflow_run = mlflow_client .create_run (experiment_id = experiment_id , run_name = model .input_filename )
516
516
model .mlflow_run_id = mlflow_run .info .run_id
517
517
518
518
job = Job (** model .dict (exclude_none = True , exclude = {"input_uri" }))
@@ -663,7 +663,7 @@ def create_job_definition(self, model: CreateJobDefinition) -> str:
663
663
raise InputUriError (model .input_uri )
664
664
665
665
mlflow_client = mlflow .MlflowClient ()
666
- experiment_id = mlflow_client .create_experiment (f"{ model .name } -{ uuid4 ()} " )
666
+ experiment_id = mlflow_client .create_experiment (f"{ model .input_filename } -{ uuid4 ()} " )
667
667
model .mlflow_experiment_id = experiment_id
668
668
input_file_path = os .path .join (self .root_dir , model .input_uri )
669
669
mlflow .log_artifact (input_file_path , "input" )
0 commit comments