def store_async_marker(async_id, status):

    logging.debug("Attempting to mark Async %s complete.", async_id)

    # QUESTION: Do we trust if the marker had a flag result to just trust it?
    marker = FuriousAsyncMarker.get_by_id(async_id)

    if marker:
        logging.debug("Marker already exists for %s.", async_id)
        return

    # TODO: Handle exceptions and retries here.
    key = FuriousAsyncMarker(id=async_id, status=status).put()

    logging.debug("Marked Async complete using marker: %s.", key)
Persist a marker indicating the Async ran to the datastore.
dataset/ETHPy150Open Workiva/furious/furious/extras/appengine/ndb_persistence.py/store_async_marker