[ https://issues.apache.org/jira/browse/AIRFLOW-6562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Work on AIRFLOW-6562 started by t oo. ------------------------------------- > mushroom cloud error when clicking 'mark failed/success' from graph view of > dag that has never been run yet > ----------------------------------------------------------------------------------------------------------- > > Key: AIRFLOW-6562 > URL: https://issues.apache.org/jira/browse/AIRFLOW-6562 > Project: Apache Airflow > Issue Type: Bug > Components: ui > Affects Versions: 1.10.6 > Environment: localexec, mysql metastore, 1.10.6 > Reporter: t oo > Assignee: t oo > Priority: Major > > # create a new dag > # go to graph view > # click on one of the tasks (it should have a white border) > # click on 'past/future' on either 2nd last row (mark failed) or last row > (mark success) > # then click either (mark failed) or (mark success) > below error appears > Traceback (most recent call last): > File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 2446, in > wsgi_app > response = self.full_dispatch_request() > File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 1951, in > full_dispatch_request > rv = self.handle_user_exception(e) > File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 1820, in > handle_user_exception > reraise(exc_type, exc_value, tb) > File "/usr/local/lib/python3.7/site-packages/flask/_compat.py", line 39, in > reraise > raise value > File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 1949, in > full_dispatch_request > rv = self.dispatch_request() > File "/usr/local/lib/python3.7/site-packages/flask/app.py", line 1935, in > dispatch_request > return self.view_functions[rule.endpoint](**req.view_args) > File "/usr/local/lib/python3.7/site-packages/flask_admin/base.py", line 69, > in inner > return self._run_view(f, *args, **kwargs) > File "/usr/local/lib/python3.7/site-packages/flask_admin/base.py", line 368, > in _run_view > return fn(self, *args, **kwargs) > File "/usr/local/lib/python3.7/site-packages/flask_login/utils.py", line > 258, in decorated_view > return func(*args, **kwargs) > File "/usr/local/lib/python3.7/site-packages/airflow/www/utils.py", line > 290, in wrapper > return f(*args, **kwargs) > File "/usr/local/lib/python3.7/site-packages/airflow/www/utils.py", line > 337, in wrapper > return f(*args, **kwargs) > File "/usr/local/lib/python3.7/site-packages/airflow/www/views.py", line > 1449, in failed > future, past, State.FAILED) > File "/usr/local/lib/python3.7/site-packages/airflow/www/views.py", line > 1420, in _mark_task_instance_state > commit=False) > File "/usr/local/lib/python3.7/site-packages/airflow/utils/db.py", line 74, > in wrapper > return func(*args, **kwargs) > File > "/usr/local/lib/python3.7/site-packages/airflow/api/common/experimental/mark_tasks.py", > line 105, in set_state > dates = get_execution_dates(dag, execution_date, future, past) > File > "/usr/local/lib/python3.7/site-packages/airflow/api/common/experimental/mark_tasks.py", > line 246, in get_execution_dates > raise ValueError("Received non-localized date {}".format(execution_date)) > ValueError: Received non-localized date 2020-01-14T21:58:44.855743+00:00 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)