From f7a1832e217251c59598056c2cc4c44c11fecc88 Mon Sep 17 00:00:00 2001 From: schneefux Date: Sun, 26 Feb 2017 19:58:19 +0100 Subject: support multiple threads per worker --- api.py | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) diff --git a/api.py b/api.py index 5c7528d..885795e 100644 --- a/api.py +++ b/api.py @@ -129,15 +129,18 @@ class Worker(object): logging.info("nothing to do, idling") await asyncio.sleep(10) + async def start(self, number=1): + """Start jobs in background.""" + for _ in range(number): + asyncio.ensure_future(self.run()) async def startup(): - for _ in range(1): - worker = Worker() - await worker.connect( - source_db, dest_db - ) - await worker.setup() - await worker.run() + worker = Worker() + await worker.connect( + source_db, dest_db + ) + await worker.setup() + await worker.start(10) logging.basicConfig(level=logging.DEBUG) loop = asyncio.get_event_loop() -- cgit v1.3.1