from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor from apscheduler.schedulers.blocking import BlockingScheduler from queue_message.CookiesPublisher import MORNING_DATA_CACHE from request_sender_test import send_request_for_file_list def start_book_appointment(): file_list = ['~/Desktop/contact_list_2024-05-19.xlsx', '~/Desktop/contact_list_2024-05-17.xlsx', '~/Desktop/15_05_to_test.xlsx'] send_request_for_file_list(file_list=file_list, thread_number=32, data_queue_name=MORNING_DATA_CACHE) def start_check_results_job(sched): sched.add_job(start_book_appointment, 'cron', day_of_week='mon-sat', hour='10', minute='30', misfire_grace_time=10, second='20', timezone='Europe/Paris', max_instances=1, args=[]) def config_and_start_jobs(): executors = { 'default': ThreadPoolExecutor(30), 'processpool': ProcessPoolExecutor(12) } sched = BlockingScheduler(executors=executors) start_check_results_job(sched) sched.print_jobs() sched.start() if __name__ == '__main__': config_and_start_jobs()