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

Fix Pipeline controller function support for dict as input argument

Browse Source
This commit is contained in:
allegroai 2022-01-05 08:56:56 +02:00
parent 94da6af843
commit de6ea269f8
2 changed files with 3 additions and 3 deletions
clearml/automation
controller.pytrigger.py

4
clearml/automation/controller.py
View File

@ -1143,10 +1143,10 @@ class PipelineController(object):
self._task._set_configuration( self._task._set_configuration(
name=self._config_section, config_type='dictionary', name=self._config_section, config_type='dictionary',
config_text=json.dumps(pipeline_dag, indent=2)) config_text=json.dumps(pipeline_dag, indent=2))
params.update(self._pipeline_args) params.update(flatten_dictionary(self._pipeline_args))
# noinspection PyProtectedMember # noinspection PyProtectedMember
self._task._set_parameters( self._task._set_parameters(
{'{}/{}'.format(self._args_section, k): str(v) for k, v in params.items()}, {'{}/{}'.format(self._args_section, k): v for k, v in params.items()},
__parameters_descriptions=self._pipeline_args_desc, __parameters_descriptions=self._pipeline_args_desc,
__update=True, __update=True,
) )

2
clearml/automation/trigger.py
View File

@ -247,7 +247,7 @@ class TriggerScheduler(BaseScheduler):
(skip until the next scheduled time period). Default False. (skip until the next scheduled time period). Default False.
:param reuse_task: If True, re-enqueue the same Task (i.e. do not clone it) every time, default False. :param reuse_task: If True, re-enqueue the same Task (i.e. do not clone it) every time, default False.
:param task_parameters: Configuration parameters to the executed Task. :param task_parameters: Configuration parameters to the executed Task.
for example: {'Args/batch': '12'} Notice: not available when reuse_task=True/ for example: {'Args/batch': '12'} Notice: not available when reuse_task=True
:param task_overrides: Change task definition. :param task_overrides: Change task definition.
for example {'script.version_num': None, 'script.branch': 'main'} Notice: not available when reuse_task=True for example {'script.version_num': None, 'script.branch': 'main'} Notice: not available when reuse_task=True
:return: True if job is successfully added to the scheduling list :return: True if job is successfully added to the scheduling list