From 67d6633951fdd558d206654c6ff2aec742be4ef1 Mon Sep 17 00:00:00 2001 From: Lei PAN Date: Wed, 15 May 2024 10:29:02 +0200 Subject: [PATCH] default queue MORNING_DATA_CACHE --- request_sender_test.py | 7 ++++--- scheduler_test.py | 2 +- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/request_sender_test.py b/request_sender_test.py index 5ca058e..dc61d44 100644 --- a/request_sender_test.py +++ b/request_sender_test.py @@ -67,7 +67,7 @@ def send_appointment_request(message_queue_name, _contact_list): receiver.run() -def start_send_requests(thread_number, file_path): +def start_send_requests(thread_number, file_path, data_queue_name=MORNING_DATA_CACHE): print("start send requests") contacts_file_path = file_path _contact_list = read_contacts(contacts_file_path) @@ -79,11 +79,12 @@ def start_send_requests(thread_number, file_path): logger.info("segment is {}".format(i)) _step = int(len(_contact_list_to_book) / _segment_number) _sublist = _contact_list_to_book[i * _step:_step * (i + 1)] - _thread1 = Thread(target=send_appointment_request, args=(MORNING_DATA_CACHE_2, _sublist)) + _thread1 = Thread(target=send_appointment_request, args=(data_queue_name, _sublist)) last_thread = _thread1 _thread1.start() last_thread.join() if __name__ == '__main__': - start_send_requests(thread_number=28, file_path='~/Desktop/contact_list_2024-05-10.xlsx') + start_send_requests(thread_number=30, file_path='~/Desktop/contact_list_2024-05-14.xlsx', + data_queue_name=MORNING_DATA_CACHE_2) diff --git a/scheduler_test.py b/scheduler_test.py index f347f07..137da42 100644 --- a/scheduler_test.py +++ b/scheduler_test.py @@ -5,7 +5,7 @@ from request_sender_test import start_send_requests def start_book_appointment(): - start_send_requests(thread_number=28, file_path='~/Desktop/contact_list_2024-05-10.xlsx') + start_send_requests(thread_number=31, file_path='~/Desktop/contact_list_2024-05-14.xlsx') def start_check_results_job(sched):