ClearML/clearml
1
0
Fork 0
mirror of https://github.com/clearml/clearml synced 2025-06-26 18:16:07 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Fix Process Pool hangs at exit (#674)

Browse Source
This commit is contained in:
allegroai 2022-05-12 23:49:09 +03:00
parent 5dff9dd404
commit b5c3477f06
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
clearml/task.py
View File

@ -2058,7 +2058,6 @@ class Task(_Task):
""" """
Get user properties for this task. Get user properties for this task.
Returns a dictionary mapping user property name to user property details dict. Returns a dictionary mapping user property name to user property details dict.
:param value_only: If True, returned user property details will be a string representing the property value. :param value_only: If True, returned user property details will be a string representing the property value.
""" """
if not Session.check_min_api_version("2.9"): if not Session.check_min_api_version("2.9"):
@ -3482,6 +3481,7 @@ class Task(_Task):
elif task_status[0] == 'failed': elif task_status[0] == 'failed':
self.mark_failed(status_reason=task_status[1]) self.mark_failed(status_reason=task_status[1])
elif task_status[0] == 'completed': elif task_status[0] == 'completed':
self.set_progress(100)
self.mark_completed() self.mark_completed()
elif task_status[0] == 'stopped': elif task_status[0] == 'stopped':
self.stopped() self.stopped()
@ -3519,9 +3519,6 @@ class Task(_Task):
pass pass
self._edit_lock = None self._edit_lock = None
if task_status and task_status[0] == "completed":
self.set_progress(100)
# make sure no one will re-enter the shutdown method # make sure no one will re-enter the shutdown method
self._at_exit_called = True self._at_exit_called = True
if not is_sub_process and BackgroundMonitor.is_subprocess_enabled(): if not is_sub_process and BackgroundMonitor.is_subprocess_enabled():