You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Muthuraj Ramasamy (JIRA)" <ji...@apache.org> on 2017/03/27 19:09:41 UTC

[jira] [Assigned] (AIRFLOW-1044) Run from UI with Ignore Task Debs not working

     [ https://issues.apache.org/jira/browse/AIRFLOW-1044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Muthuraj Ramasamy reassigned AIRFLOW-1044:
------------------------------------------

    Assignee: Muthuraj Ramasamy

> Run from UI with Ignore Task Debs not working
> ---------------------------------------------
>
>                 Key: AIRFLOW-1044
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-1044
>             Project: Apache Airflow
>          Issue Type: Bug
>            Reporter: Muthuraj Ramasamy
>            Assignee: Muthuraj Ramasamy
>            Priority: Minor
>
> When "Run" is performed on a task with Ignore Task Debs from UI, its not passed to the command formation and not getting started. The reason is ignore_task_deps property is not set in the init defintion of BaseTaskRunner [base_task_runner.py].
> Current:
>            self._command = popen_prepend + self._task_instance.command_as_list(
>             raw=True,
>             ignore_all_deps=local_task_job.ignore_all_deps,
>             ignore_depends_on_past=local_task_job.ignore_depends_on_past,
>             ignore_ti_state=local_task_job.ignore_ti_state,
>             pickle_id=local_task_job.pickle_id,
>             mark_success=local_task_job.mark_success,
>             job_id=local_task_job.id,
>             pool=local_task_job.pool,
>             cfg_path=cfg_path,
>         )
> Fixed:
>             self._command = popen_prepend + self._task_instance.command_as_list(
>             raw=True,
>             ignore_all_deps=local_task_job.ignore_all_deps,
>             ignore_depends_on_past=local_task_job.ignore_depends_on_past,
>             ignore_task_deps=local_task_job.ignore_task_deps,
>             ignore_ti_state=local_task_job.ignore_ti_state,
>             pickle_id=local_task_job.pickle_id,
>             mark_success=local_task_job.mark_success,
>             job_id=local_task_job.id,
>             pool=local_task_job.pool,
>             cfg_path=cfg_path,
>         )



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)