Fix running pipeline code remotely without first running it locally (i.e. no configuration on the Task)

This commit is contained in:
allegroai 2022-05-22 20:03:10 +03:00
parent d22dff59ee
commit 60a73ca931

View File

@ -641,7 +641,7 @@ class PipelineController(object):
packages, project_name, task_name, packages, project_name, task_name,
task_type, repo, repo_branch, repo_commit, helper_functions) task_type, repo, repo_branch, repo_commit, helper_functions)
elif self._task.running_locally(): elif self._task.running_locally() or self._task.get_configuration_object(name=name) is None:
project_name = project_name or self._get_target_project() or self._task.get_project_name() project_name = project_name or self._get_target_project() or self._task.get_project_name()
task_definition = self._create_task_from_function( task_definition = self._create_task_from_function(
@ -1218,7 +1218,9 @@ class PipelineController(object):
# serialize pipeline state # serialize pipeline state
if self._task and self._auto_connect_task: if self._task and self._auto_connect_task:
if self._task.running_locally(): # check if we are either running locally or that we are running remotely,
# but we have no configuration, so we need to act as if this is a local run and create everything
if self._task.running_locally() or self._task.get_configuration_object(name=self._config_section) is None:
# noinspection PyProtectedMember # noinspection PyProtectedMember
self._task._set_configuration( self._task._set_configuration(
name=self._config_section, config_type='dictionary', name=self._config_section, config_type='dictionary',