def execution_context_from_async(async):
    local_context = _local.get_local_context()

    if local_context._executing_async_context:
        raise errors.ContextExistsError

    execution_context = _ExecutionContext(async)
    local_context._executing_async_context = execution_context
    return execution_context
Run the container audit until stopped.
dataset/ETHPy150Open Workiva/furious/furious/context/_execution.py/execution_context_from_async--crossover with--dataset/ETHPy150Open openstack/swift/swift/container/auditor.py/ContainerAuditor.run_forever