def context_completion_checker(async):

    store_async_marker(async.id, async.result.status if async.result else -1)

    logging.debug("Async check completion for: %s", async.context_id)
    current_queue = _get_current_queue()
    from furious.async import Async
    logging.debug("Completion Check queue:%s", current_queue)
    Async(_completion_checker, queue=current_queue,
          args=(async.id, async.context_id)).start()

    return True
Ensure to_task produces the right task object.
dataset/ETHPy150Open Workiva/furious/furious/extras/appengine/ndb_persistence.py/context_completion_checker--crossover with--dataset/ETHPy150Open Workiva/furious/furious/tests/test_async.py/TestAsync.test_to_task