chore: reduced sleep time to 0.3 sec

PowerLoom · Oct 25, 2024 · c17d1e7 · c17d1e7
1 parent 27b9aa5
commit c17d1e7
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/snapshotter/utils/aggregation_worker.py b/snapshotter/utils/aggregation_worker.py
@@ -336,8 +336,8 @@ async def _on_rabbitmq_message(self, message: IncomingMessage):
             )
             return
         self._create_tracked_task(self._processor_task(msg_obj=msg_obj, task_type=task_type))
-        # sleep for 1 second
-        await asyncio.sleep(1)
+        # sleep for 0.3 second
+        await asyncio.sleep(0.3)
         await message.ack()
 
     async def _init_project_calculation_mapping(self):

diff --git a/snapshotter/utils/snapshot_worker.py b/snapshotter/utils/snapshot_worker.py
@@ -402,8 +402,8 @@ async def _on_rabbitmq_message(self, message: IncomingMessage):
 
         # Start the processor task
         self._create_tracked_task(self._process_task(msg_obj=msg_obj, task_type=task_type))
-        # sleep for 1 second
-        await asyncio.sleep(1)
+        # sleep for 0.3 second
+        await asyncio.sleep(0.3)
         await message.ack()
 
     async def _init_project_calculation_mapping(self):