make sure job is always defined, remove unused placeholders from logs
This commit is contained in:
parent
01c7392a61
commit
c506fe1e9f
|
@ -36,6 +36,7 @@ class WorkerContext:
|
|||
active_pid: "Value[int]",
|
||||
idle: "Value[bool]",
|
||||
):
|
||||
self.job = None
|
||||
self.name = name
|
||||
self.device = device
|
||||
self.cancel = cancel
|
||||
|
|
|
@ -67,15 +67,15 @@ def worker_main(worker: WorkerContext, server: ServerContext):
|
|||
logger.trace("worker reached end of queue, setting idle flag")
|
||||
worker.set_idle()
|
||||
except KeyboardInterrupt:
|
||||
logger.info("worker got keyboard interrupt")
|
||||
logger.debug("worker got keyboard interrupt")
|
||||
worker.fail()
|
||||
exit(EXIT_INTERRUPT)
|
||||
except RetryException:
|
||||
logger.info("retry error in worker, exiting: %s")
|
||||
logger.exception("retry error in worker, exiting")
|
||||
worker.fail()
|
||||
exit(EXIT_ERROR)
|
||||
except ValueError:
|
||||
logger.exception("value error in worker, exiting: %s")
|
||||
logger.exception("value error in worker, exiting")
|
||||
worker.fail()
|
||||
exit(EXIT_ERROR)
|
||||
except Exception as e:
|
||||
|
|
Loading…
Reference in New Issue