You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Jakub Powierza (JIRA)" <ji...@apache.org> on 2017/06/14 07:26:00 UTC
[jira] [Created] (AIRFLOW-1304) Airflow "test" command checks
dependencies
Jakub Powierza created AIRFLOW-1304:
---------------------------------------
Summary: Airflow "test" command checks dependencies
Key: AIRFLOW-1304
URL: https://issues.apache.org/jira/browse/AIRFLOW-1304
Project: Apache Airflow
Issue Type: Bug
Affects Versions: 1.8.1
Reporter: Jakub Powierza
Priority: Minor
According to [docs|https://airflow.incubator.apache.org/cli.html] "test" command:
{code}
(...) will run a task without checking for dependencies (...)
{code}
But as I've seen this is not true. I've recently tried to run test for one of my task that was already in running state. It gave me this error and didn't run at all:
{code}
2017-06-08 15:04:52,281:DEBUG:root:[CT=None] <TaskInstance: my_dag_name.my_task_name 2017-06-08 14:35:00 [running]> dependency 'Trigger Rule' PASSED: True, Context specified all task dependencies should be ignored.
2017-06-08 15:04:52,281:WARNING:py.warnings:[CT=None] /Users/username/Projects/my_project/venv/lib/python3.5/site-packages/airflow/models.py:1140: PendingDeprecationWarning: generator 'get_dep_statuses' raised StopIteration
dep_context):
2017-06-08 15:04:52,282:DEBUG:root:[CT=None] <TaskInstance: my_dag_name.my_task_name 2017-06-08 14:35:00 [running]> dependency 'Task Instance State' PASSED: True, Context specified that state should be ignored.
2017-06-08 15:04:52,283:WARNING:py.warnings:[CT=None] /Users/username/Projects/my_project/venv/lib/python3.5/site-packages/airflow/ti_deps/deps/base_ti_dep.py:94: PendingDeprecationWarning: generator '_get_dep_statuses' raised StopIteration
for dep_status in self._get_dep_statuses(ti, session, dep_context):
2017-06-08 15:04:52,284:DEBUG:root:[CT=None] <TaskInstance: my_dag_name.my_task_name 2017-06-08 14:35:00 [running]> dependency 'Not In Retry Period' PASSED: True, Context specified all task dependencies should be ignored.
2017-06-08 15:04:52,284:DEBUG:root:[CT=None] <TaskInstance: my_dag_name.my_task_name 2017-06-08 14:35:00 [running]> dependency 'Task Instance Not Already Running' PASSED: False, Task is already running, it started on 2017-06-08 15:02:34.736972.
2017-06-08 15:04:52,284:INFO:root:[CT=None] Dependencies not met for <TaskInstance: my_dag_name.my_task_name 2017-06-08 14:35:00 [running]>, dependency 'Task Instance Not Already Running' FAILED: Task is already running, it started on 2017-06-08 15:02:34.736972.
2017-06-08 15:04:52,284:DEBUG:root:[CT=None] <TaskInstance: my_dag_name.my_task_name 2017-06-08 14:35:00 [running]> dependency 'Previous Dagrun State' PASSED: True, Context specified all task dependencies should be ignored.
{code}
Please remove this information from docs or prepare a fix for above issue.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)