diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-02-28 18:21:07 +0100 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-02-28 18:21:07 +0100 |
| commit | 0da3a298562bede77e596ff3dd8d9879c900319a (patch) | |
| tree | 34eb81a9ff5b339561a1b7a36cfb2e598a55ee4a /api.py | |
| parent | 701086e4b97dd940af4d3a2783e10b586ce33641 (diff) | |
| parent | 911cff2384de8146d32cb2b14ff1625bfba679c5 (diff) | |
| download | processor-0da3a298562bede77e596ff3dd8d9879c900319a.tar.gz processor-0da3a298562bede77e596ff3dd8d9879c900319a.zip | |
Merge branch 'quiet-logs' into develop
Diffstat (limited to 'api.py')
| -rw-r--r-- | api.py | 4 |
1 files changed, 0 insertions, 4 deletions
@@ -61,7 +61,6 @@ class Worker(object): explicit_player = payload["playername"] async with self._srcpool.acquire() as srccon: async with self._destpool.acquire() as destcon: - logging.debug("%s: processing '%s'", jobid, object_id) async with srccon.transaction(): async with destcon.transaction(): # 1 object in raw : n objects in web @@ -159,10 +158,8 @@ class Worker(object): jobtype="process") if jobid is None: raise LookupError("no jobs available") - logging.debug("%s: starting job", jobid) await self._execute_job(jobid, payload, priority) await self._queue.finish(jobid) - logging.debug("%s: finished job", jobid) async def run(self): """Start jobs forever.""" @@ -170,7 +167,6 @@ class Worker(object): try: await self._work() except LookupError: - logging.info("nothing to do, idling") await asyncio.sleep(10) async def start(self, number=1): |
