def METHOD_NAME(self, plan_context, execution_plan):
    from .core_execution_loop import core_celery_execution_loop
    return core_celery_execution_loop(
        plan_context, execution_plan, step_execution_fn=_submit_task
    )