feat: change redis check interval to 30s

idoknow · Jun 26, 2024 · a173710 · a173710
1 parent 2935a15
commit a173710
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/campux/mq/redis.py b/campux/mq/redis.py
@@ -73,7 +73,7 @@ async def routine_loop():
                 await self.process_stream(streams_name['campux_redis_publish_post_stream'], self.check_publish_post)
                 await self.process_stream(streams_name['campux_redis_new_post_stream'], self.check_new_post)
                 await self.process_stream(streams_name['campux_redis_post_cancel_stream'], self.check_post_cancel)
-                await asyncio.sleep(10)
+                await asyncio.sleep(30)
 
         asyncio.create_task(routine_loop())