From f96f5da864f14faf65e51548ed62ecf9dae07629 Mon Sep 17 00:00:00 2001 From: wuaho Date: Wed, 28 Jul 2021 20:19:22 +0800 Subject: [PATCH] =?UTF-8?q?=E5=87=8F=E5=B0=91=E6=89=B9=E9=87=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/app.py b/app.py index 97d08d2..6424826 100644 --- a/app.py +++ b/app.py @@ -24,8 +24,8 @@ class XProcess(Process): handler_user = HandlerUser(db_client, settings.GAME) transmitter = Transmitter(db_client, settings.GAME, sketch, self.log, self.lock, self.event_attr, self.partition) - transmitter.add_source(handler_event, 2000, 60) - transmitter.add_source(handler_user, 99, 60) + transmitter.add_source(handler_event, 5000, 60) + transmitter.add_source(handler_user, 500, 60) last_ts = int(time.time()) consumer = create_consumer(self.partition)