[
https://issues.apache.org/jira/browse/AIRFLOW-95?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bence Nagy updated AIRFLOW-95:
------------------------------
Description:
Affected version: {{dddfd3b5bf2cabaac6eec123dfa3cb59e73a56f5}}
Steps to reproduce:
1. Add any DAG with a task depending on another
2. Go to the web UI's tree view
3. Click the depended upon task's latest execution
4. Click the 'Downstream' button next 'Mark Success', then click 'Mark Success'
This gives me the following exception (but only if there's at least one
downstream task that should be selected):
{code}
Traceback (most recent call last):
File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1817, in
wsgi_app
response = self.full_dispatch_request()
File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1477, in
full_dispatch_request
rv = self.handle_user_exception(e)
File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1381, in
handle_user_exception
reraise(exc_type, exc_value, tb)
File "/usr/local/lib/python3.5/site-packages/flask/_compat.py", line 33, in
reraise
raise value
File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1475, in
full_dispatch_request
rv = self.dispatch_request()
File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1461, in
dispatch_request
return self.view_functions[rule.endpoint](**req.view_args)
File "/usr/local/lib/python3.5/site-packages/flask_admin/base.py", line 68,
in inner
return self._run_view(f, *args, **kwargs)
File "/usr/local/lib/python3.5/site-packages/flask_admin/base.py", line 367,
in _run_view
return fn(self, *args, **kwargs)
File "/usr/local/lib/python3.5/site-packages/flask_login.py", line 755, in
decorated_view
return func(*args, **kwargs)
File "/usr/local/lib/python3.5/site-packages/airflow/www/utils.py", line 118,
in wrapper
return f(*args, **kwargs)
File "/usr/local/lib/python3.5/site-packages/airflow/www/utils.py", line 167,
in wrapper
return f(*args, **kwargs)
File "/usr/local/lib/python3.5/site-packages/airflow/www/views.py", line
1185, in success
task=task_id_to_dag[task_id].get_task(task_id),
KeyError: 'id_of_downstream_task'
{code}
was:
Steps to reproduce:
1. Add any DAG with a task depending on another
2. Go to the web UI's tree view
3. Click the depended upon task's latest execution
4. Click the 'Downstream' button next 'Mark Success', then click 'Mark Success'
This gives me the following exception (but only if there's at least one
downstream task that should be selected):
{code}
Traceback (most recent call last):
File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1817, in
wsgi_app
response = self.full_dispatch_request()
File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1477, in
full_dispatch_request
rv = self.handle_user_exception(e)
File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1381, in
handle_user_exception
reraise(exc_type, exc_value, tb)
File "/usr/local/lib/python3.5/site-packages/flask/_compat.py", line 33, in
reraise
raise value
File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1475, in
full_dispatch_request
rv = self.dispatch_request()
File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1461, in
dispatch_request
return self.view_functions[rule.endpoint](**req.view_args)
File "/usr/local/lib/python3.5/site-packages/flask_admin/base.py", line 68,
in inner
return self._run_view(f, *args, **kwargs)
File "/usr/local/lib/python3.5/site-packages/flask_admin/base.py", line 367,
in _run_view
return fn(self, *args, **kwargs)
File "/usr/local/lib/python3.5/site-packages/flask_login.py", line 755, in
decorated_view
return func(*args, **kwargs)
File "/usr/local/lib/python3.5/site-packages/airflow/www/utils.py", line 118,
in wrapper
return f(*args, **kwargs)
File "/usr/local/lib/python3.5/site-packages/airflow/www/utils.py", line 167,
in wrapper
return f(*args, **kwargs)
File "/usr/local/lib/python3.5/site-packages/airflow/www/views.py", line
1185, in success
task=task_id_to_dag[task_id].get_task(task_id),
KeyError: 'id_of_downstream_task'
{code}
> 'Mark downstream tasks as successful' raises an exception
> ---------------------------------------------------------
>
> Key: AIRFLOW-95
> URL: https://issues.apache.org/jira/browse/AIRFLOW-95
> Project: Apache Airflow
> Issue Type: Bug
> Environment: EC2 t2.medium instance,
> Docker `version 1.11.1, build 5604cbe`,
> Host is `Linux ip-172-31-44-140 3.13.0-85-generic #129-Ubuntu SMP Thu Mar 17
> 20:50:15 UTC 2016 x86_64 x86_64 x86_64 GNU/Linux`,
> Docker containers are built upon the `python:3.5` image,
> LocalExecutor is used with two scheduler containers running,
> Airflow @ dddfd3b5bf2cabaac6eec123dfa3cb59e73a56f5
> Reporter: Bence Nagy
>
> Affected version: {{dddfd3b5bf2cabaac6eec123dfa3cb59e73a56f5}}
> Steps to reproduce:
> 1. Add any DAG with a task depending on another
> 2. Go to the web UI's tree view
> 3. Click the depended upon task's latest execution
> 4. Click the 'Downstream' button next 'Mark Success', then click 'Mark
> Success'
> This gives me the following exception (but only if there's at least one
> downstream task that should be selected):
> {code}
> Traceback (most recent call last):
> File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1817, in
> wsgi_app
> response = self.full_dispatch_request()
> File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1477, in
> full_dispatch_request
> rv = self.handle_user_exception(e)
> File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1381, in
> handle_user_exception
> reraise(exc_type, exc_value, tb)
> File "/usr/local/lib/python3.5/site-packages/flask/_compat.py", line 33, in
> reraise
> raise value
> File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1475, in
> full_dispatch_request
> rv = self.dispatch_request()
> File "/usr/local/lib/python3.5/site-packages/flask/app.py", line 1461, in
> dispatch_request
> return self.view_functions[rule.endpoint](**req.view_args)
> File "/usr/local/lib/python3.5/site-packages/flask_admin/base.py", line 68,
> in inner
> return self._run_view(f, *args, **kwargs)
> File "/usr/local/lib/python3.5/site-packages/flask_admin/base.py", line
> 367, in _run_view
> return fn(self, *args, **kwargs)
> File "/usr/local/lib/python3.5/site-packages/flask_login.py", line 755, in
> decorated_view
> return func(*args, **kwargs)
> File "/usr/local/lib/python3.5/site-packages/airflow/www/utils.py", line
> 118, in wrapper
> return f(*args, **kwargs)
> File "/usr/local/lib/python3.5/site-packages/airflow/www/utils.py", line
> 167, in wrapper
> return f(*args, **kwargs)
> File "/usr/local/lib/python3.5/site-packages/airflow/www/views.py", line
> 1185, in success
> task=task_id_to_dag[task_id].get_task(task_id),
> KeyError: 'id_of_downstream_task'
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
