diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-02-28 17:56:22 +0100 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-02-28 17:56:22 +0100 |
| commit | 7d34e23ecda9c1bdb5f822d90142d51cf81c0681 (patch) | |
| tree | 2c7053ba8b9e43e64139345eb4f5e4d83bcc1ffb | |
| parent | 2e0da58ea9e826bea3d6a966400cbd7a7e09236f (diff) | |
| download | compiler-7d34e23ecda9c1bdb5f822d90142d51cf81c0681.tar.gz compiler-7d34e23ecda9c1bdb5f822d90142d51cf81c0681.zip | |
logs: be more quiet
| -rw-r--r-- | api.py | 4 |
1 files changed, 0 insertions, 4 deletions
@@ -57,7 +57,6 @@ class Worker(object): object_id = payload["id"] table = payload["type"] if table not in self._queries: - logging.debug("%s: nothing to do", jobid) return async with self._pool.acquire() as con: logging.debug("%s: compiling '%s' from '%s'", @@ -71,10 +70,8 @@ class Worker(object): jobid, payload, _ = await self._queue.acquire(jobtype="compile") if jobid is None: raise LookupError("no jobs available") - logging.debug("%s: starting job", jobid) await self._execute_job(jobid, payload) await self._queue.finish(jobid) - logging.debug("%s: finished job", jobid) async def run(self): """Start jobs forever.""" @@ -82,7 +79,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): |
