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)
