[jira] [Created] (AIRFLOW-95) Mark downstream tasks successful raises an exception

["Bence Nagy (JIRA)" <ji...@apache.org>]

Bence Nagy created AIRFLOW-95:
---------------------------------

             Summary: Mark downstream tasks 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


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)