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

Fix created pipelines do not appear in the UI pipelines section

Browse Source
This commit is contained in:
allegroai 2024-01-12 12:32:55 +02:00
parent 92ab713920
commit 830dc451d2
2 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
clearml/automation/controller.py
View File

@ -311,7 +311,7 @@ class PipelineController(object):
if not self._task:
task_name = name or project or '{}'.format(datetime.now())
if self._pipeline_as_sub_project:
parent_project = (project + "/" if project else "") + self._pipeline_section
parent_project = (project + "/" if project else "") + self._project_section
project_name = "{}/{}".format(parent_project, task_name)
else:
parent_project = None
@ -1428,7 +1428,7 @@ class PipelineController(object):
mutually_exclusive(pipeline_id=pipeline_id, pipeline_project=pipeline_project, _require_at_least_one=False)
mutually_exclusive(pipeline_id=pipeline_id, pipeline_name=pipeline_name, _require_at_least_one=False)
if not pipeline_id:
pipeline_project_hidden = "{}/{}/{}".format(pipeline_project, cls._pipeline_section, pipeline_name)
pipeline_project_hidden = "{}/{}/{}".format(pipeline_project, cls._project_section, pipeline_name)
name_with_runtime_number_regex = r"^{}( #[0-9]+)*$".format(re.escape(pipeline_name))
pipelines = Task._query_tasks(
pipeline_project=[pipeline_project_hidden],

9
clearml/automation/scheduler.py
View File

@ -66,8 +66,13 @@ class BaseScheduleJob(object):
# noinspection PyBroadException
try:
task = Task.get_task(task_id=self.base_task_id)
if PipelineController._tag in task.get_system_tags() and "/{}/".format(PipelineController._pipeline_section) not in self.target_project:
return "{}/{}/{}".format(self.target_project, PipelineController._pipeline_section, task.name)
# noinspection PyProtectedMember
if (
PipelineController._tag in task.get_system_tags()
and "/{}/".format(PipelineController._project_section) not in self.target_project
):
# noinspection PyProtectedMember
return "{}/{}/{}".format(self.target_project, PipelineController._project_section, task.name)
except Exception:
pass
return self.target_project