ClearML/clearml
1
0
Fork 0
mirror of https://github.com/clearml/clearml synced 2025-04-26 17:30:20 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix race condition in pipeline declaration

Browse Source
This commit is contained in:
allegroai 2023-04-30 15:22:52 +03:00
parent 422807555d
commit c58f8649a2
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
clearml/automation/controller.py
View File

@ -4164,8 +4164,6 @@ class PipelineDecorator(PipelineController):
a_pipeline._task._set_runtime_properties(
dict(multi_pipeline_counter=str(cls._multi_pipeline_call_counter)))
a_pipeline._start(wait=False)
# sync arguments back (post deserialization and casting back)
for k in pipeline_kwargs.keys():
if k in a_pipeline.get_parameters():
@ -4178,6 +4176,8 @@ class PipelineDecorator(PipelineController):
a_pipeline._task.execute_remotely(queue_name=pipeline_execution_queue)
# when we get here it means we are running remotely
a_pipeline._start(wait=False)
# this time the pipeline is executed only on the remote machine
try:
pipeline_result = func(**pipeline_kwargs)