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 04:18:41 UTC
[jira] [Created] (AIRFLOW-1044) Run from UI with Ignore Task Debs
not working
Muthuraj Ramasamy created AIRFLOW-1044:
------------------------------------------
Summary: 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
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)