Resultados de la búsqueda a petición "celery-task"

1 la respuesta

Empleado de apiladores ImportError: Ningún módulo llamado 'proyecto'

Mientras intentaba iniciar el trabajador, tuve un problema: ImportError: Ningún módulo llamado 'proyecto' Rastreo (llamadas recientes más última) File "/usr/local/bin/celery", line 11, in <module> sys.exit(main()) ...

0 la respuesta

Cómo iniciar una tarea solo cuando todas las demás tareas hayan terminado en Apio

En Celery, quiero comenzar una tarea solo cuando todas las demás tareas se hayan completado. Encontré algunos recursos como este:Apio que inicia una tarea cuando otras tareas se han ...

1 la respuesta

¿Cómo hacer dos tareas mutuamente excluyentes en Apio?

¿Hay alguna manera de no permitir que dos tareas diferentes se ejecuten simultáneamente en Celery? Estaba pensando en definir una nueva cola con nivel de concurrencia = 1 y enviar esas tareas a esa cola, pero no pude encontrar un ejemplo. ¿Es eso ...

3 la respuesta

error de importación en el apio

Este es el código que estoy ejecutando:

3 la respuesta

Apio detener la ejecución de una cadena.

Tengo una tarea check_orders que se ejecuta periódicamente. Hace un grupo de tareas para que pueda medir el tiempo de ejecución de las tareas, y realizar alg...

1 la respuesta

La mejor manera de asignar una lista generada a una tarea en apio

Estoy buscando algunos consejos sobre la mejor manera de asignar una lista generada de una tarea a otra tarea en el apio.Digamos que tengo una tarea llamada

1 la respuesta

¿Recuperando GroupResult de tasket_id en Celery?

2 la respuesta

Reintentando tareas fallidas de apio que forman parte de una cadena

Tengo una cadena de apio que ejecuta algunas tareas. Cada una de las tareas puede fallar y ser reintentado. Vea a continuación un ejemplo rápido:

3 la respuesta

¿Cómo hacer que una tarea de apio falle desde dentro de la tarea?

Bajo ciertas condiciones, quiero hacer que una tarea de apio falle desde dentro de esa tarea. Intenté lo siguiente: from celery.task import task from celery import states @task() def run_simulation(): if ...

7 la respuesta

Eliminar todas las tareas pendientes en apio / rabbitmq

¿Cómo puedo eliminar todas las tareas pendientes sin conocer latask_id para cada tarea?