From 75591188227c40120fb32b22192a866261e09460 Mon Sep 17 00:00:00 2001 From: "francisco.schulz" Date: Thu, 11 Jul 2024 14:50:11 -0400 Subject: [PATCH] fix: remove sleep commands --- scripts/test_async_class.py | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/scripts/test_async_class.py b/scripts/test_async_class.py index 8a66d8f..d5cd616 100644 --- a/scripts/test_async_class.py +++ b/scripts/test_async_class.py @@ -261,6 +261,7 @@ async def test_rabbitmq_handler(): handler = RabbitMQHandler(connection_params, tenant_service_url, dummy_message_processor) await handler.connect() + await handler.initialize_tenant_queues() await handler.setup_tenant_queue() # Test tenant creation @@ -271,17 +272,11 @@ async def test_rabbitmq_handler(): ) logger.info(f"Sent create tenant message for {tenant_id}") - # Wait for tenant queue creation - await asyncio.sleep(2) - # Test service request service_request = upload_json_and_make_message_body(tenant_id) await handler.input_exchange.publish(Message(body=json.dumps(service_request).encode()), routing_key=tenant_id) logger.info(f"Sent service request for {tenant_id}") - # Wait for message processing - await asyncio.sleep(5) - # Test tenant deletion delete_message = tenant_event_message(tenant_id) await handler.tenant_exchange.publish( @@ -289,9 +284,6 @@ async def test_rabbitmq_handler(): ) logger.info(f"Sent delete tenant message for {tenant_id}") - # Wait for tenant queue deletion - await asyncio.sleep(2) - await handler.connection.close()