diff --git a/request_sender.py b/request_sender.py index d6e237e..cb36878 100644 --- a/request_sender.py +++ b/request_sender.py @@ -71,7 +71,7 @@ def send_appointment_request(message_queue_name, _contact_list): def start_send_requests(): print("start send requests") - contacts_file_path = '~/Desktop/contact_list_2024-04-06-2.xlsx' + contacts_file_path = '~/Desktop/contact_list_2024-04-16_2.xlsx' _contact_list = read_contacts(contacts_file_path) _contact_list_to_book = filter_contacts(_contact_list) _segment_number = 10 diff --git a/scheduler_test.py b/scheduler_test.py new file mode 100644 index 0000000..28144d7 --- /dev/null +++ b/scheduler_test.py @@ -0,0 +1,30 @@ +from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor +from apscheduler.schedulers.blocking import BlockingScheduler + +from request_sender_test import start_send_requests + + +def start_book_appointment(): + start_send_requests() + + +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='0', 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()