Estoy usando APScheduler en una aplicación FastAPI. Tengo una tabla, donde almacené mis tareas asíncronas. Luego, usando APScheduler, me gustaría leer esta tabla cada hora y agregar nuevos trabajos (uno por fila de la tabla) a la cola. Estos trabajos son livianos, por lo que creo que usar apio es excesivo. Sin embargo, tengo dificultades para iniciar un trabajo dentro de otro trabajo para APScheduler. Entonces, la pregunta es ¿cómo se puede agregar un trabajo dentro de otro trabajo? Cualquier idea o ayuda es apreciada.
También he tenido un problema con esto y una solución simple es tener el programador como una variable global disponible en el módulo del trabajo. Es posible que también deba usar el almacén de memoria, ya que permite pasar objetos no serializables.
También puede pasar el programador al trabajo, siempre que el trabajo se ejecute en un ejecutor que no requiera que los argumentos se serialicen.
Por ejemplo, puede tener un trabajo periódico ejecutándose en el ejecutor asyncio que obtiene el programador como argumento y le agrega más trabajos, que se ejecutarán con el ejecutor de ProcessPool.
Para obtener más información, consulte estadiscusión en el canal de Gitter