[
https://issues.apache.org/jira/browse/AIRFLOW-3422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820958#comment-16820958
]
Ash Berlin-Taylor commented on AIRFLOW-3422:
--------------------------------------------
Oh it turns out that AIRFLOW-4308 may have actually fixed this!
Before that commit:
{noformat}
2018-10-03 16:30:00+00:00
2018-10-04 16:30:00+00:00
2018-10-05 16:30:00+00:00
2018-10-06 15:30:00+00:00
2018-10-06 15:30:00+00:00
2018-10-06 15:30:00+00:00
2018-10-06 15:30:00+00:00
2018-10-06 15:30:00+00:00
2018-10-06 15:30:00+00:00
{noformat}
After that commit
{noformat}
2018-10-03 16:30:00+00:00
2018-10-04 16:30:00+00:00
2018-10-05 16:30:00+00:00
2018-10-06 16:30:00+00:00
2018-10-07 15:30:00+00:00
2018-10-08 15:30:00+00:00
2018-10-09 15:30:00+00:00
2018-10-10 15:30:00+00:00
2018-10-11 15:30:00+00:00
{noformat}
> Infinite loops during springtime DST transitions on python 3.6
> --------------------------------------------------------------
>
> Key: AIRFLOW-3422
> URL: https://issues.apache.org/jira/browse/AIRFLOW-3422
> Project: Apache Airflow
> Issue Type: Bug
> Components: scheduler
> Affects Versions: 1.10.1
> Reporter: Till Heistermann
> Priority: Major
> Fix For: 2.0.0
>
>
> Automatic DST transitions can cause dags to be stuck in an infinite loop, if
> they happen to be scheduled in the "skipped" hour during a springtime DST
> transition.
> The fix introduced in https://issues.apache.org/jira/browse/AIRFLOW-3277 does
> not seem to work for python 3.6, only for 3.5 and 2.7.
> Example to reproduce (current master, python 3.6):
> {code:java}
> import pendulum
> from datetime import datetime
> from airflow.utils.timezone import make_aware
> from airflow.models import DAG
> nsw = pendulum.Timezone.load("Australia/Sydney")
> dt = make_aware(datetime(2018, 10, 3, 2, 30), nsw)
> dag = DAG("id", schedule_interval="30 2 * * *", start_date=dt)
> dt = dag.following_schedule(dt); print(dt)
> dt = dag.following_schedule(dt); print(dt)
> dt = dag.following_schedule(dt); print(dt)
> dt = dag.following_schedule(dt); print(dt)
> dt = dag.following_schedule(dt); print(dt)
> dt = dag.following_schedule(dt); print(dt)
> dt = dag.following_schedule(dt); print(dt)
> dt = dag.following_schedule(dt); print(dt)
> dt = dag.following_schedule(dt); print(dt)
> {code}
>
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
