Tengo dificultades para entender cómo funciona AsyncIOScheduler y cómo puedo programar una función dentro de la función principal, o cuál es la forma correcta de hacerlo.

¿Cómo puedo ejecutar la función foo cada 10 segundos?

Supongamos que tengo esta estructura:

 package/ controllers.py main.py

Del archivo controllers.py tengo una función llamada foo y la función es algo como esto:

 async def foo(): print('Hello World')

Me gustaría ejecutar la función foo (y muchas otras) desde el archivo main.py , y este archivo es como:

 import asyncio from controllers import foo, bar from apscheduler.schedulers.asyncio import AsyncIOScheduler async def main(): # Init message print('\nPress Ctrl-C to quit at anytime!\n' ) await asyncio.create_task(bar()) scheduler = AsyncIOScheduler() scheduler.add_job(await asyncio.create_task(foo()), "interval", seconds=10) scheduler.start() if __name__ == "__main__": while True: try: asyncio.run(main()) except Exception as e: print("Exception: " + str(e))

¿Es correcto ejecutar el programador de esta manera? ¿O el temporizador se reiniciará cada vez que se ejecute la función principal?

Probé el siguiente código, el intervalo de bucle funciona, pero la función main no.

 import asyncio from controllers import foo, bar from apscheduler.schedulers.asyncio import AsyncIOScheduler async def main(): # Init message print('\nPress Ctrl-C to quit at anytime!\n' ) await asyncio.create_task(bar()) if __name__ == "__main__": scheduler = AsyncIOScheduler() scheduler.add_job(foo, "interval", seconds=10) scheduler.start() while True: try: asyncio.get_event_loop().run_forever() asyncio.run(main()) except Exception as e: print("Exception: " + str(e))

Si cambié el orden de:

 asyncio.get_event_loop().run_forever() asyncio.run(main())

para:

 asyncio.run(main()) asyncio.get_event_loop().run_forever()

Recibo el error: There is no current event loop in thread 'MainThread'.

El ciclo funciona (solo programador), pero la función main no se está ejecutando, ¿cómo puedo juntarlos en un ciclo?