set default queue to MORNING_DATA_CACHE
This commit is contained in:
@@ -79,7 +79,7 @@ def start_send_requests(thread_number, file_path):
|
|||||||
logger.info("segment is {}".format(i))
|
logger.info("segment is {}".format(i))
|
||||||
_step = int(len(_contact_list_to_book) / _segment_number)
|
_step = int(len(_contact_list_to_book) / _segment_number)
|
||||||
_sublist = _contact_list_to_book[i * _step:_step * (i + 1)]
|
_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=(MORNING_DATA_CACHE, _sublist))
|
||||||
last_thread = _thread1
|
last_thread = _thread1
|
||||||
_thread1.start()
|
_thread1.start()
|
||||||
last_thread.join()
|
last_thread.join()
|
||||||
|
|||||||
Reference in New Issue
Block a user