bluek1te commented on issue #27582: URL: https://github.com/apache/airflow/issues/27582#issuecomment-1311185737
Sure, just tested it again, before 9:25PM CST:  After 9:25PM CST:  Logs from scheduler (Debug turned on, let me know if you want logs without it turned on: At 03:24:59 ``` [2022-11-11 03:24:59,400] {retries.py:84} DEBUG - Running SchedulerJob._create_dagruns_for_dags with retries. Try 1 of 3 [2022-11-11 03:24:59,406] {retries.py:84} DEBUG - Running SchedulerJob._get_next_dagruns_to_examine with retries. Try 1 of 3 [2022-11-11 03:24:59,411] {retries.py:84} DEBUG - Running SchedulerJob._get_next_dagruns_to_examine with retries. Try 1 of 3 [2022-11-11 03:24:59,412] {retries.py:84} DEBUG - Running SchedulerJob._schedule_all_dag_runs with retries. Try 1 of 3 [2022-11-11 03:24:59,420] {scheduler_job.py:342} DEBUG - No tasks to consider for execution. [2022-11-11 03:24:59,421] {base_executor.py:163} DEBUG - 0 running task instances [2022-11-11 03:24:59,421] {base_executor.py:164} DEBUG - 0 in queue [2022-11-11 03:24:59,421] {base_executor.py:165} DEBUG - 32 open slots [2022-11-11 03:24:59,421] {base_executor.py:174} DEBUG - Calling the <class 'airflow.executors.celery_executor.CeleryExecutor'> sync method [2022-11-11 03:24:59,421] {celery_executor.py:330} DEBUG - No task to query celery, skipping sync [2022-11-11 03:24:59,421] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:24:59,421] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:24:59,421] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:24:59,421] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:24:59,422] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:24:59,422] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:24:59,422] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:24:59,422] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:24:59,422] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:24:59,422] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:24:59,422] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:24:59,432] {scheduler_job.py:879} DEBUG - Next timed event is in 0.864662 [2022-11-11 03:24:59,432] {scheduler_job.py:881} DEBUG - Ran scheduling loop in 0.03 seconds ``` At 03:25:00 ``` [2022-11-11 03:25:00,298] {retries.py:84} DEBUG - Running SchedulerJob._create_dagruns_for_dags with retries. Try 1 of 3 [2022-11-11 03:25:00,303] {retries.py:84} DEBUG - Running SchedulerJob._get_next_dagruns_to_examine with retries. Try 1 of 3 [2022-11-11 03:25:00,309] {retries.py:84} DEBUG - Running SchedulerJob._get_next_dagruns_to_examine with retries. Try 1 of 3 [2022-11-11 03:25:00,309] {retries.py:84} DEBUG - Running SchedulerJob._schedule_all_dag_runs with retries. Try 1 of 3 [2022-11-11 03:25:00,317] {scheduler_job.py:342} DEBUG - No tasks to consider for execution. [2022-11-11 03:25:00,318] {base_executor.py:163} DEBUG - 0 running task instances [2022-11-11 03:25:00,318] {base_executor.py:164} DEBUG - 0 in queue [2022-11-11 03:25:00,318] {base_executor.py:165} DEBUG - 32 open slots [2022-11-11 03:25:00,318] {base_executor.py:174} DEBUG - Calling the <class 'airflow.executors.celery_executor.CeleryExecutor'> sync method [2022-11-11 03:25:00,318] {celery_executor.py:330} DEBUG - No task to query celery, skipping sync [2022-11-11 03:25:00,318] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:25:00,318] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:25:00,318] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:25:00,318] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:25:00,318] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:25:00,319] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:25:00,319] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:25:00,319] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:25:00,319] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:25:00,319] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:25:00,319] {manager.py:275} DEBUG - Received message of type DagParsingStat [2022-11-11 03:25:00,331] {scheduler_job.py:879} DEBUG - Next timed event is in 4.446577 [2022-11-11 03:25:00,331] {scheduler_job.py:881} DEBUG - Ran scheduling loop in 0.03 seconds ``` -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
