diff --git a/migrate_cached_request_data.py b/migrate_cached_request_data.py index 2784cc6..6026e9c 100644 --- a/migrate_cached_request_data.py +++ b/migrate_cached_request_data.py @@ -5,9 +5,9 @@ from queue_message.CookiesPublisher import MORNING_DATA_CACHE_2, MORNING_DATA_CA from workers.MessagerTransporter import migrate_message_to_queue if __name__ == '__main__': - # p1 = Process(target=migrate_message_to_queue, args=(MORNING_DATA_CACHE_2, MORNING_DATA_CACHE_BAK)) - # p1.start() - p2 = Process(target=migrate_message_to_queue, args=(MORNING_DATA_CACHE_BAK, REGISTER_QUEUE)) + p1 = Process(target=migrate_message_to_queue, args=(MORNING_DATA_CACHE, MORNING_DATA_CACHE_BAK)) + p1.start() + p2 = Process(target=migrate_message_to_queue, args=(MORNING_DATA_CACHE_2, MORNING_DATA_CACHE_BAK)) p2.start() p2.join() # migrate_message_to_queue(from_queue=MORNING_DATA_CACHE_2)