@@ -510,17 +510,14 @@ def create_workflow_from_json(self, json_object: json, reference_flop_rate: str,
510510 "ignore_avg_cpu" : ignore_avg_cpu ,
511511 "show_warnings" : show_warnings }
512512
513- sys .stderr .write ("HERE\n " )
514-
515513 r = self .__send_request_to_daemon (requests .post , f"{ self .daemon_url } /{ self .simid } /createWorkflowFromJSON" ,
516514 json_data = data )
517515 response = r .json ()
518516
519517 # Create the workflow
520518 workflow = Workflow (self , response ["workflow_name" ])
521519
522- sys .stderr .write ("CREATING TASKS\n " )
523- # Create the tasks
520+ # Create the tasks (caching parameter values)
524521 for task_spec in response ["tasks" ]:
525522 task_name = task_spec ["name" ]
526523 task_flops = task_spec ["flops" ]
@@ -530,15 +527,12 @@ def create_workflow_from_json(self, json_object: json, reference_flop_rate: str,
530527 workflow .tasks [task_name ] = Task (self , workflow , task_name , task_flops , task_min_num_cores , task_max_num_cores , task_memory )
531528
532529
533- # Create the files
534- sys .stderr .write ("CREATING FILES\n " )
530+ # Create the files (caching parameter values)
535531 print (response ["files" ])
536532 for file_spec in response ["files" ]:
537533 file_name = file_spec ["name" ]
538534 file_size = file_spec ["size" ]
539- sys .stderr .write (f"---> { file_name } : { file_size } \n " )
540535 self .files [file_name ] = File (self , file_name , file_size )
541- sys .stderr .write ("CREATED FILES\n " )
542536
543537 return workflow
544538
0 commit comments