panleicim/appointment_request
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

change thread_number to 60

Browse Source
This commit is contained in:
PAN Lei
2024-08-05 15:33:09 +02:00
parent e4cdae2f2e
commit df833b5ac8
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
request_sender_test.py
+1
View File
@@ -89,6 +89,7 @@ def start_send_requests(thread_number, contact_list, data_queue_name=MORNING_DAT
def send_request_for_file_list(file_list: list, thread_number: int = 20, data_queue_name=MORNING_DATA_CACHE, def send_request_for_file_list(file_list: list, thread_number: int = 20, data_queue_name=MORNING_DATA_CACHE,
stop_at_hour=11, stop_at_mins=30): stop_at_hour=11, stop_at_mins=30):
logger.info("stop_at_hour is " + str(stop_at_hour) + " stop_at_mins is " + str(stop_at_mins))
for _file_path in file_list: for _file_path in file_list:
logger.info("send request for file: " + _file_path) logger.info("send request for file: " + _file_path)
_contact_list = read_contacts(_file_path) _contact_list = read_contacts(_file_path)
scheduler_test.py
+5 -6
View File
@@ -6,20 +6,19 @@ from request_sender_test import send_request_for_file_list
def start_book_appointment(): def start_book_appointment():
file_list = ['~/Desktop/contact_list_2024-05-27.xlsx', file_list = ['~/Desktop/contact_list_2024-07-31.xlsx',
'~/Desktop/contact_list_2024-05-25.xlsx', '~/Desktop/contact_list_2024-05-25.xlsx',
'~/Desktop/contact_list_2024-05-24.xlsx', '~/Desktop/contact_list_2024-05-24.xlsx',
'~/Desktop/contact_list_2024-05-23.xlsx', '~/Desktop/contact_list_2024-06-26.xlsx']
'~/Desktop/contact_list_2024-05-22.xlsx'] send_request_for_file_list(file_list=file_list, thread_number=60,
send_request_for_file_list(file_list=file_list, thread_number=40, data_queue_name=MORNING_DATA_CACHE, stop_at_hour=11, stop_at_mins=40)
data_queue_name=MORNING_DATA_CACHE)
def start_check_results_job(sched): def start_check_results_job(sched):
sched.add_job(start_book_appointment, 'cron', day_of_week='mon-sat', hour='10', sched.add_job(start_book_appointment, 'cron', day_of_week='mon-sat', hour='10',
minute='30', minute='30',
misfire_grace_time=10, misfire_grace_time=10,
second='20', timezone='Europe/Paris', max_instances=1, args=[]) second='10', timezone='Europe/Paris', max_instances=1, args=[])
def config_and_start_jobs(): def config_and_start_jobs():