Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Tengo una tarea que se ve así (por supuesto, el método run es más complejo): class SomeTask(celery.Task): max_retries = 3 acks_late = True def run(self): print(‘some code’) Sé que celery tiene opciones de reintentos y atraso de confirmación. Necesito usar acks_late. Así que me pregunto: ¿max_retries = 3 limita la . . . Read more
Tengo un montón de instancias de Fargate en AWS, y tienen celery ejecutándose en ellas localmente con Elasticache para redis. Debido a las políticas de Auto Scaling, las instancias siguen apareciendo y desapareciendo, el problema es que las tareas de celery se ejecutan tantas veces como réplicas de mi servidor. . . . Read more
Estoy desarrollando un conjunto de pruebas para una aplicación Flask utilizando Celery para procesar tareas en segundo plano. Estoy trabajando en pruebas de integración y he estado intentando configurar un worker en vivo embebido según la documentación (https://docs.celeryproject.org/en/latest/userguide/testing.html) conftest.py @pytest.fixture(scope=’session’) def celery_config(): return { ‘broker_url’: ‘memory://localhost/’, ‘result_backend’: ‘memory://localhost/’, } @pytest.fixture(scope=’module’) . . . Read more
Tengo que implementar una comprobación para verificar si mis tareas de celery ya han sido creadas, por eso estoy intentando inspeccionar las colas de rabbitmq y buscar los ids de las tareas cada vez que llamo a .delay() o apply_async(). El problema es que hay muchas firmas pasándose en mi . . . Read more
Estoy utilizando django-celery-beat para algunas tareas por hora/día. Sin embargo, un comportamiento extraño me ha dejado perplejo sobre qué hacer. Estoy creando una tarea utilizando este fragmento de código: periodic_task = apps.get_model(‘django_celery_beat’, ‘PeriodicTask’) interval_schedule = apps.get_model(‘django_celery_beat’, ‘IntervalSchedule’) schedule, _ = interval_schedule.objects.get_or_create(every=2, period=’hours’) periodic_task.objects.update_or_create( task=TASK, defaults={‘name’: ‘<descripción de=”” la=”” tarea=””>’, ‘interval’: . . . Read more