ClearML/clearml
1
0
Fork 0
mirror of https://github.com/clearml/clearml synced 2025-01-31 09:07:00 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #145 from H4dr1en/patch-3

Browse Source 
Add task.wait_for_status()
This commit is contained in:
Allegro AI 2020-06-17 21:47:28 +03:00 committed by GitHub
commit 1475f0e98d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
trains/task.py
View File

@ -13,7 +13,7 @@ try:
except ImportError:
from collections import Callable, Sequence as CollectionsSequence
from typing import Optional, Union, Mapping, Sequence, Any, Dict, TYPE_CHECKING
from typing import Optional, Union, Mapping, Sequence, Any, Dict, TYPE_CHECKING, Iterable
import psutil
import six
@ -2484,3 +2484,22 @@ class Task(_Task):
exit(0)
return
def wait_for_status(self, status=(tasks.TaskStatusEnum.completed),
raise_on_status=(tasks.TaskStatusEnum.failed),
check_interval_sec=60):
# type: (Iterable[tasks.TaskStatusEnum], Iterable[tasks.TaskStatusEnum], int) -> ()
"""
Wait for a task to reach a defined status.
:param status: Status to wait for. Defaults to ('completed')
:param raise_on_status: Raise RuntimeError if the status of the tasks matches one of these values.
Defaults to ('failed').
:param check_interval_sec: Interval in seconds between two checks. Defaults to 60 seconds.
:raise: RuntimeError if the status is one of {raise_on_status}.
"""
while self.status not in status or self.status not in raise_on_status:
time.sleep(check_interval_sec)
if self.status in raise_on_status:
raise RuntimeError("Task {} has status: {}.".format(self.task_id, self.status))