Creando tarea periódica

Hola,

Según como puso el profe la tarea periodica, se desactivarían viajes que aún no han terminado, pero que como máximo terminarán dentro del timedelta que ahora es 5 segundos, pero que podría ser 20 minutos.

No sería mejor que desactive aquellas que como máximo terminaron hace lo que fuera el timedelta, de modo que desactivamos los viajes terminados hacia atrás y así damos chance de que lo pueda desactivar el user y toda la implementación del action finish del ride tenga razón de ser y el periodic task sea solo si el user olvidó terminar el ride, a modo de correción, que era la razón de ser del periodic task que dijo el profe.

Slds

Le dejo forma de llamar a periodic_task pero con crontab por si tienen la misma duda que yo.

from celery.task.schedules import crontab
from celery.decorators import periodic_task

@periodic_task(name='disable_finished_rides', 'run_every=crontab(hour=7, minute=30, day_of_week=1))
def disable_finished_rides():
    pass

Cuando esten trabajando con las ultimas versiones de Celery podran notar que la forma de trabajar cambio.

Para este caso particular de las tareas programadas la implementacion se hace de esta forma:

"""Beat tasks configuration"""

# Django
from django.utils import timezone

# Celery
from cride.taskapp.celery import app
from celery import shared_task

# Models
from cride.rides.models import Ride

# Utilities
from datetime import timedelta


@shared_task(name='disable_finished_rides')
def disable_finished_rides():
    """Disable finished rides."""
    now = timezone.now()
    offset = now + timedelta(seconds=5)
    rides = Ride.objects.filter(arrival_date__gte=now,
                                arrival_date__lte=offset,
                                is_active=True)
    rides.update(is_active=False)


app.conf.beat_schedule = {
    'disable-finished-rides': {
        'task': 'disable_finished_rides',
        'schedule': 10
    }
}

pueden encontrar mas detalles en la documentacion

Actualmente deben importar task de la siguiente manera.

from cride.taskapp.celery import app

@app.task(name='send_confirmation_email', max_retries=3)

Flower: App escrita en Django que permite monitorear el cluster de celery

🤙👍