Tag: CELERY
Buen día. Soy un principiante con Celery y estoy teniendo dificultades para encontrar una solución a mi problema. Mi aplicación de Celery funciona bien cuando estoy usando Redis como el backend de resultados. Intenté cambiar mi backend de resultados de Redis a MySQL. La tarea se ejecuta correctamente cuando uso . . . Read more
Tengo Pytest funcionando para probar las tareas de Celery basado en esta pregunta y respuesta de Stack Overflow: Fixture de prueba de Celery en Pytest (celery-worker y celery-app) no funciona. conftest.py import pytest @pytest.fixture(scope=”session”) def celery_config(): return { “broker_url”: REDIS_URL, “result_backend”: REDIS_URL, } Las pruebas pasan con la configuración siguiente: . . . Read more
Recientemente, me encuentro con un error al iniciar los workers en modo prefork en Celery (5.2.3). Aquí está su rastreo de pila: [2022-01-06 00:56:18,535: ERROR/ForkPoolWorker-1] Proceso ForkPoolWorker-1 Traceback (most recent call last): File “/Users/bryan/workplace/.venv/lib/python3.9/site-packages/billiard/process.py”, line 327, in _bootstrap self.run() File “/Users/bryan/workplace/.venv/lib/python3.9/site-packages/billiard/process.py”, line 114, in run self._target(*self._args, **self._kwargs) File “/Users/bryan/workplace/.venv/lib/python3.9/site-packages/billiard/pool.py”, line . . . Read more
Estoy utilizando Celery para paralelizar la ejecución de una función de Python que llama a una API de terceros. Esta API impone esperar al menos 3 segundos entre cada llamada. ¿Hay alguna forma de especificar un Mensaje Broker (RabbitMQ o Redis) para respetar este retraso entre cada llamada de los . . . Read more
Tengo un redis sentinel funcionando. Puedo conectarme a él con código python y hacer ping sin problemas (código abajo). Sin embargo, cuando intento conectar mi aplicación celery a este redis sentinel, obtengo el mensaje de “no se encontró el maestro para ‘mymaster’”. ¿Probablemente tengo algunas configuraciones incorrectas? Tanto mi maestro . . . Read more