You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Jonathan Lange (Jira)" <ji...@apache.org> on 2019/09/10 15:22:00 UTC
[jira] [Commented] (AIRFLOW-5452) "Mark Success" stops at last
schedule_interval change
[ https://issues.apache.org/jira/browse/AIRFLOW-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16926725#comment-16926725 ]
Jonathan Lange commented on AIRFLOW-5452:
-----------------------------------------
Clarifying: "Mark Successful" "Past" yields an empty "Wait a minute" page.
"Mark Successful" "Future" yields the following exception
{noformat}
____/ ( ( ) ) \___
/( ( ( ) _ )) ) )\
(( ( )( ) ) ( ) )
((/ ( _( ) ( _) ) ( () ) )
( ( ( (_) (( ( ) .((_ ) . )_
( ( ) ( ( ) ) ) . ) ( )
( ( ( ( ) ( _ ( _) ). ) . ) ) ( )
( ( ( ) ( ) ( )) ) _)( ) ) )
( ( ( \ ) ( (_ ( ) ( ) ) ) ) )) ( )
( ( ( ( (_ ( ) ( _ ) ) ( ) ) )
( ( ( ( ( ) (_ ) ) ) _) ) _( ( )
(( ( )( ( _ ) _) _(_ ( (_ )
(_((__(_(__(( ( ( | ) ) ) )_))__))_)___)
((__) \\||lll|l||/// \_))
( /(/ ( ) ) )\ )
( ( ( ( | | ) ) )\ )
( /(| / ( )) ) ) )) )
( ( ((((_(|)_))))) )
( ||\(|(|)|/|| )
( |(||(||)|||| )
( //|/l|||)|\\ \ )
(/ / // /|//||||\\ \ \ \ _)
-------------------------------------------------------------------------------
Node: 10.1.73.14
-------------------------------------------------------------------------------
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 281, in wrapper
return f(*args, **kwargs)
File "/usr/local/lib/python3.7/site-packages/airflow/www/utils.py", line 328, in wrapper
return f(*args, **kwargs)
File "/usr/local/lib/python3.7/site-packages/airflow/www/views.py", line 1471, in success
future, past, State.SUCCESS)
File "/usr/local/lib/python3.7/site-packages/airflow/www/views.py", line 1422, 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 103, 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 261, in get_execution_dates
dates = dag.date_range(start_date=start_date, end_date=end_date)
File "/usr/local/lib/python3.7/site-packages/airflow/models/dag.py", line 357, in date_range
num=num, delta=self._schedule_interval)
File "/usr/local/lib/python3.7/site-packages/airflow/utils/dates.py", line 88, in date_range
end_date = timezone.make_naive(end_date, tz)
File "/usr/local/lib/python3.7/site-packages/airflow/utils/timezone.py", line 146, in make_naive
o = value.astimezone(timezone)
File "/usr/local/lib/python3.7/site-packages/pendulum/tz/timezone_info.py", line 99, in fromutc
tzinfo = self._tz._tzinfos[self._tz._transitions[idx]._tzinfo_index]
IndexError: list index out of range{noformat}
> "Mark Success" stops at last schedule_interval change
> -----------------------------------------------------
>
> Key: AIRFLOW-5452
> URL: https://issues.apache.org/jira/browse/AIRFLOW-5452
> Project: Apache Airflow
> Issue Type: Bug
> Components: models
> Affects Versions: 1.10.5
> Reporter: Jonathan Lange
> Priority: Major
> Attachments: Screenshot 2019-09-10 at 15.48.29.png
>
>
> I recently added a new task to a long-running DAG. I wanted to mark it as successful from yesterday's run right back to when the task began.
> I did this by clicking on the task instance for yesterday's run. This was blank, as I would expect for a new task. I then clicked "Mark Success" "Past".
> The last 21 tasks were marked as successful, but it stopped there. Note also that the "Wait a minute" page only listed 21 tasks.
> After chatting on Slack ([https://apache-airflow.slack.com/archives/CCQ7EGB1P/p1568126090457700]), I realised that we changed the schedule interval around then.
> Before this watershed, I can mark individual tasks as successful, but I cannot mark tasks as successful en masse. When I try, I get an empty "Wait a minute" page, and clicking through yields no change.
> "models" component is something of a guess. I don't really know where this issue belongs.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)