diff --git a/app.py b/app.py index e2b09c4..97d08d2 100644 --- a/app.py +++ b/app.py @@ -24,7 +24,7 @@ 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, 5000, 60) + transmitter.add_source(handler_event, 2000, 60) transmitter.add_source(handler_user, 99, 60) last_ts = int(time.time()) consumer = create_consumer(self.partition)