Introducción

Ejecute tareas asincio en apio de vainilla

import asyncio

from .celeryapp import celeryapp


async def async_task():
    await asyncio.sleep(42)


@celeryapp.task
def regular_task():
    coro = async_task()
    asyncio.run(coro)

• ¡Funciona!
• Simplemente
• Sin dependencias externas adicionales

• Event Loop se crea dentro de cada trabajador.
• No hay cambio de contexto entre la ejecución de corutinas
• En un momento dado, el trabajador ejecuta no más de una rutina
• Los recursos compartidos no se comparten entre tareas
• Repetitivo

Vamos a intentar más complicado?

import asyncio
import threading

from .celeryapp import celeryapp

celeryapp.loop = asyncio.get_event_loop()
celeryapp.loop_runner = threading.Thread(
    target=celeryapp.loop.run_forever,
    daemon=True,
)
celeryapp.loop_runner.start()

async def async_task():
    await asyncio.sleep(42)


@celeryapp.task
def regular_task():
    coro = async_task()
    asyncio.run_coroutine_threadsafe(
        coro=coro,
        loop=celeryapp.loop,
    )

• Aún trabajando
• Aún más o menos efectivo
• Incluso los recursos se mezclan entre las rutinas dentro del trabajador.
• Todavía no hay dependencias externas adicionales

• El apio no sabe nada sobre correr corutina
• Pierdes el control sobre la ejecución de tareas
• Pierdes el control de las excepciones.
• Repetitivo

Formulación del problema

• Deberia trabajar
• Las rutinas deben ser competitivas
• Los recursos deben compartirse entre muchos ejecutables
• Sin repetitivo
• API predecible simple

import asyncio

from .celeryapp import celeryapp


@celeryapp.task
async def async_task():
    await asyncio.sleep(42)

Resumen

Características brevemente

• Eliminación de tareas asincrónicas
• Soporte de corutina en señales de apio

Planes

Ejemplos

Otro