[jira] [Commented] (AIRFLOW-969) Catch bad python_callable argument at DAG construction rather than Task run

["ASF subversion and git services (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/AIRFLOW-969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958483#comment-15958483 ] 

ASF subversion and git services commented on AIRFLOW-969:
---------------------------------------------------------

Commit 916741171cc0c6426dbcbe8a2b5ce2468fce870d in incubator-airflow's branch refs/heads/v1-8-test from abloomston
[ https://git-wip-us.apache.org/repos/asf?p=incubator-airflow.git;h=9167411 ]

[AIRFLOW-969] Catch bad python_callable argument

Checks for callable when Operator is
created, not when it is run.

* added initial PythonOperator unit test, testing
run
* python_callable must be callable; added unit
test

Closes #2142 from abloomston/python-callable

(cherry picked from commit 12901ddfa9961a11feaa3f17696d19102ff8ecd0)
Signed-off-by: Bolke de Bruin <bo...@xs4all.nl>


> Catch bad python_callable argument at DAG construction rather than Task run
> ---------------------------------------------------------------------------
>
>                 Key: AIRFLOW-969
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-969
>             Project: Apache Airflow
>          Issue Type: Improvement
>          Components: operators
>            Reporter: Adam Bloomston
>            Assignee: Adam Bloomston
>            Priority: Minor
>             Fix For: 1.9.0
>
>
> If a non-callable parameter for python_callable is passed to PythonOperator, it should fail to instantiate.  This will move such failures from task run to DAG instantiation. Better to catch such errors sooner rather than later in execution.



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