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)