async def METHOD_NAME(flow_run_id_2, task_id):
    """
    A task run in a Running state
    """
    task_run_id = await api.runs.get_or_create_task_run(
        flow_run_id=flow_run_id_2, task_id=task_id, map_index=None
    )
    await api.states.set_task_run_state(task_run_id=task_run_id, state=Running())
    return task_run_id