from utils.logging import logging def thread_pool_executor_callback(worker): exc = worker.exception() if exc: logging.exception("worker %s got exception %s", worker, exc)