nemunaire/nemubot
1
0
Fork 0
Code Releases Activity

event: ensure that enough consumers are launched at the end of an event

Browse Source
This commit is contained in:
nemunaire 2017-07-16 18:39:56 +02:00
parent 2a25f5311a
commit 5b28828ede
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
nemubot/bot.py
View File

@ -207,6 +207,9 @@ class Bot(threading.Thread):
elif action == "exit": elif action == "exit":
self.quit() self.quit()
elif action == "launch_consumer":
pass # This is treated after the loop
elif action == "loadconf": elif action == "loadconf":
for path in args: for path in args:
logger.debug("Load configuration from %s", path) logger.debug("Load configuration from %s", path)
@ -418,6 +421,7 @@ class Bot(threading.Thread):
while len(self.events) > 0 and datetime.now(timezone.utc) >= self.events[0].current: while len(self.events) > 0 and datetime.now(timezone.utc) >= self.events[0].current:
evt = self.events.pop(0) evt = self.events.pop(0)
self.cnsr_queue.put_nowait(EventConsumer(evt)) self.cnsr_queue.put_nowait(EventConsumer(evt))
sync_act("launch_consumer")
self._update_event_timer() self._update_event_timer()