You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "phanikumv (via GitHub)" <gi...@apache.org> on 2023/06/06 16:48:28 UTC

[GitHub] [airflow] phanikumv commented on issue #31723: The Airflow scheduler crashes when configuring start_date for future date, setting schedule_interval and max_active_runs

phanikumv commented on issue #31723:
URL: https://github.com/apache/airflow/issues/31723#issuecomment-1579116014

   I have tried with the below DAG and I didnt observe any issue with the scheduler.
   
   ```
   from datetime import datetime
   from airflow import DAG
   from airflow.decorators import task
   
   with DAG("future", max_active_runs=1, schedule_interval="* * * * *", start_date=datetime(2100, 1, 1)):
       @task
       def hello():
           return "Hello"
   
       hello()
   ```
   
   Scheduler logs:
   ```
   2023-06-06 22:14:05 [2023-06-06 16:44:05,515] {dagrun.py:658} INFO - DagRun Finished: dag_id=future, execution_date=2023-06-06 16:44:04.548710+00:00, run_id=manual__2023-06-06T16:44:04.548710+00:00, run_start_date=2023-06-06 16:44:05.504191+00:00, run_end_date=2023-06-06 16:44:05.515257+00:00, run_duration=0.011066, state=success, external_trigger=True, run_type=manual, data_interval_start=2023-06-06 16:43:00+00:00, data_interval_end=2023-06-06 16:44:00+00:00, dag_hash=d73b9d8cf712d028cc0aed24a86cebb5
   2023-06-06 22:14:05 [2023-06-06 16:44:05,518] {dag.py:3452} INFO - Setting next_dagrun for future to 2100-01-01T00:00:00+00:00, run_after=2100-01-01T00:01:00+00:00
   2023-06-06 22:15:48 [2023-06-06 16:45:48,223] {dagrun.py:607} INFO - Marking run <DagRun future @ 2023-06-06 16:45:47.789604+00:00: manual__2023-06-06T16:45:47.789604+00:00, state:running, queued_at: 2023-06-06 16:45:47.794337+00:00. externally triggered: True> successful
   2023-06-06 22:15:48 [2023-06-06 16:45:48,223] {dagrun.py:658} INFO - DagRun Finished: dag_id=future, execution_date=2023-06-06 16:45:47.789604+00:00, run_id=manual__2023-06-06T16:45:47.789604+00:00, run_start_date=2023-06-06 16:45:48.219590+00:00, run_end_date=2023-06-06 16:45:48.223907+00:00, run_duration=0.004317, state=success, external_trigger=True, run_type=manual, data_interval_start=2023-06-06 16:44:00+00:00, data_interval_end=2023-06-06 16:45:00+00:00, dag_hash=9629db80aa2766b6e170687b97e6015f
   2023-06-06 22:15:48 [2023-06-06 16:45:48,225] {dag.py:3452} INFO - Setting next_dagrun for future to 2100-01-01T00:00:00+00:00, run_after=2100-01-01T00:01:00+00:00
   2023-06-06 22:16:58 [2023-06-06 16:46:58,272] {scheduler_job.py:1413} INFO - Resetting orphaned tasks for active dag runs
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org