def check_complete(task, out_queue):
    logger.debug("Checking if %s is complete", task)
    try:
        is_complete = task.complete()
    except Exception:
        is_complete = TracebackWrapper(traceback.format_exc())
    out_queue.put((task, is_complete))
Checks if task is complete, puts the result to out_queue.
dataset/ETHPy150Open spotify/luigi/luigi/worker.py/check_complete