@@ -183,8 +183,8 @@ proc_name = None
#
-def when_ready(server):
- server.log.info("Server is ready. Spawning pool threads.")
+def on_starting(server):
+ server.log.info("Server is starting. Spawning pool threads.")
init_workers()
@@ -22,6 +22,7 @@ def worker():
def init_workers(count=2):
logging.info("Initializing workers...")
+ q = queue.Queue()
for _ in range(count):
threading.Thread(target=worker).start()