airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Zachary Lawson (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (AIRFLOW-1246) Setting a Subdag task Instance State Throws exception
Date Mon, 16 Oct 2017 17:23:00 GMT

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

Zachary Lawson commented on AIRFLOW-1246:
-----------------------------------------

[~kraman] I'm trying to follow the guidelines laid out here:
https://cwiki.apache.org/confluence/display/AIRFLOW/Contributors%27+Guide
Specifically:
{quote}
Create a JIRA for your bug fix/feature enhancement - point the JIRA "External Issue URL" to
your PR URL
{quote}

Looking at the issues I've created, you should be able to do this by clicking 'Edit' and then
adding the PR Url to the 'External issue URL' field under the 'Labels' field. I'd do it but
I can't because I don't own the ticket/don't have permissions.

> Setting a Subdag  task Instance State Throws exception
> ------------------------------------------------------
>
>                 Key: AIRFLOW-1246
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-1246
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: subdag
>    Affects Versions: Airflow 1.8
>            Reporter: kraman
>            Assignee: Zachary Lawson
>
> When there is a parent dag with a subdag trying to set the task instance state of any
of the task instances in the subdag to ANY of  the states"failed,running/success" throws the
below exception.
> This is nasty when running a local executor the process are not terminated and lie around
until manually killed.
> ]
> Traceback (most recent call last):
>   File "/usr/local/lib/python2.7/site-packages/flask/app.py", line 1988, in wsgi_app
>     response = self.full_dispatch_request()
>   File "/usr/local/lib/python2.7/site-packages/flask/app.py", line 1641, in full_dispatch_request
>     rv = self.handle_user_exception(e)
>   File "/usr/local/lib/python2.7/site-packages/flask/app.py", line 1544, in handle_user_exception
>     reraise(exc_type, exc_value, tb)
>   File "/usr/local/lib/python2.7/site-packages/flask/app.py", line 1639, in full_dispatch_request
>     rv = self.dispatch_request()
>   File "/usr/local/lib/python2.7/site-packages/flask/app.py", line 1625, in dispatch_request
>     return self.view_functions[rule.endpoint](**req.view_args)
>   File "/usr/local/lib/python2.7/site-packages/flask_admin/base.py", line 69, in inner
>     return self._run_view(f, *args, **kwargs)
>   File "/usr/local/lib/python2.7/site-packages/flask_admin/base.py", line 368, in _run_view
>     return fn(self, *args, **kwargs)
>   File "/usr/local/lib/python2.7/site-packages/flask_admin/model/base.py", line 2068,
in action_view
>     return self.handle_action()
>   File "/usr/local/lib/python2.7/site-packages/flask_admin/actions.py", line 113, in
handle_action
>     response = handler[0](ids)
>   File "/usr/local/lib/python2.7/site-packages/airflow/www/views.py", line 2341, in action_set_failed
>     self.set_task_instance_state(ids, State.FAILED)
>   File "/usr/local/lib/python2.7/site-packages/airflow/utils/db.py", line 53, in wrapper
>     result = func(*args, **kwargs)
>   File "/usr/local/lib/python2.7/site-packages/airflow/www/views.py", line 2383, in set_task_instance_state
>     raise Exception("Ooops")
> Exception: Ooops



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message