ClearML/clearml
1
0
Fork 0
mirror of https://github.com/clearml/clearml synced 2025-03-03 10:42:00 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Improve orchestration pipelines

Browse Source
This commit is contained in:
allegroai 2019-10-29 22:08:02 +02:00
parent 9d7c875d71
commit ac0dfabdfd
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
trains/task.py
View File

@ -1392,15 +1392,26 @@ class Task(_Task):
) )
project = get_single_result(entity='project', query=project_name, results=res.response.projects) project = get_single_result(entity='project', query=project_name, results=res.response.projects)
system_tags = 'system_tags' if hasattr(tasks.Task, 'system_tags') else 'tags'
res = cls._send( res = cls._send(
cls._get_default_session(), cls._get_default_session(),
tasks.GetAllRequest( tasks.GetAllRequest(
project=[project.id], project=[project.id],
name=exact_match_regex(task_name), name=exact_match_regex(task_name),
only_fields=['id', 'name', 'last_update'] only_fields=['id', 'name', 'last_update', system_tags]
) )
) )
task = get_single_result(entity='task', query=task_name, results=res.response.tasks, raise_on_error=False) res_tasks = res.response.tasks
# if we have more than one result, first filter 'archived' results:
if len(res_tasks) > 1:
filtered_tasks = [t for t in res_tasks if not getattr(t, system_tags, None) or
'archived' not in getattr(t, system_tags, None)]
if filtered_tasks:
res_tasks = filtered_tasks
task = get_single_result(entity='task', query=task_name, results=res_tasks, raise_on_error=False)
if not task:
return None
return cls( return cls(
private=cls.__create_protection, private=cls.__create_protection,