a 3f@sddlZddlmZddlmZmZddlmZmZddl m Z ddl m Z ddl mZdd lTdd lTdd lTdd lTdd lTd d Zd d ZdddZddZddZddZeeZeejejdZddZ dS)N)BackgroundScheduler)ProcessPoolExecutorThreadPoolExecutor)register_events register_job)DjangoJobExecution) CronTrigger)settings)*cCs(tj}|D]}|jrt|jqdS)N)Blocksobjectsall is_autonomousZautonomous_flight_time_planningid)blocksblockr-/var/www/html/django/DPS/gardens/scheduler.pyautonomous_flightss   rcCsRtjtjdd}tjjdd}|D]$}|j|jtjj dkr(t |j q(dS)N)minutesr )statustzinfo) datetimenow timedeltaFlightsr filter start_datereplacetimezoneutcZreschedule_flightr)Z late_timeflightsZchecked_flightrrrreshedule_missed_flightss  r%: cCstj|dS)aN This job deletes APScheduler job execution entries older than `max_age` from the database. It helps to prevent the database from filling up with old historical records that are no longer useful. :param max_age: The maximum length of time to retain historical job execution records. Defaults to 7 days. N)rr delete_old_job_executions)max_agerrrr'#s r'cCstjD]}|jdkrNtjj|jdD]"}tjj|jdD] }t|qs(     -