[
https://issues.apache.org/jira/browse/AIRFLOW-1027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363992#comment-16363992
]
Matthew Revell commented on AIRFLOW-1027:
-----------------------------------------
This ticket only describes one cause for this error. It can also occur for
other reasons. A more complete solution is proposed withÂ
[AIRFLOW-2099|https://issues.apache.org/jira/browse/AIRFLOW-2099]
> Task details cannot be shown when PythonOperator calls a partial function
> -------------------------------------------------------------------------
>
> Key: AIRFLOW-1027
> URL: https://issues.apache.org/jira/browse/AIRFLOW-1027
> Project: Apache Airflow
> Issue Type: Bug
> Components: ui
> Affects Versions: Airflow 1.7.1
> Reporter: Adrian Partl
> Assignee: Adrian Partl
> Priority: Minor
>
> Showing task details of a PythonOperator that uses a `functools.partial` as a
> callable results in the following error:
> {noformat}
> File "/usr/lib/python2.7/site-packages/airflow/www/views.py", line 909, in
> task
> special_attrs_rendered[attr_name] = attr_renderer[attr_name](source)
> File "/usr/lib/python2.7/site-packages/airflow/www/views.py", line 224, in
> <lambda>
> inspect.getsource(x), lexers.PythonLexer),
> File "/usr/lib64/python2.7/inspect.py", line 701, in getsource
> lines, lnum = getsourcelines(object)
> File "/usr/lib64/python2.7/inspect.py", line 690, in getsourcelines
> lines, lnum = findsource(object)
> File "/usr/lib64/python2.7/inspect.py", line 526, in findsource
> file = getfile(object)
> File "/usr/lib64/python2.7/inspect.py", line 420, in getfile
> 'function, traceback, frame, or code object'.format(object))
> TypeError: <functools.partial object at 0x5ca4d08> is not a module, class,
> method, function, traceback, frame, or code object
> {noformat}
> A sample dag definition for this is:
> {noformat}
> def func_with_two_args(arg_1, arg_2):
> pass
> partial_func = functools.partial(func_with_two_args, arg_1=1)
> dag = DAG(dag_id='test_issue_1333_dag', default_args=default_args)
> dag_task1 = PythonOperator(
> task_id='test_dagrun_functool_partial',
> dag=dag,
> python_callable=partial_func)
> {noformat}
> I will provide a PR with a fix for this.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
