rerunning failed tasks

[omargawdat]

Hello, first thanks for the package it would be great to be a replacement for celery i got a question is there any plans for adding the option for rerunning the failed tasks, or even monitor the tasks in more manageable way

[omargawdat]

I could solve the rerun issue using this signal code

import logging

from django.core.cache import cache
from django.dispatch import receiver
from django_tasks.signals import task_finished

logger = logging.getLogger(__name__)


@receiver(task_finished)
def retry_failed_tasks(sender, task_result, **kwargs):
    if task_result.status != "FAILED":
        return

    cache_key = f'task_retry_count_{task_result.id}'
    retry_count = cache.get(cache_key, 0)

    MAX_RETRY = 2
    if retry_count >= MAX_RETRY:
        logger.info(f"Task {task_result.id} has reached the maximum of {MAX_RETRY} retries.")
        return

    try:
        new_task_result = task_result.task.enqueue()
    except Exception as e:
        logger.error(f"Failed to enqueue retry for task {task_result.id}: {e}")
        return

    # Update retry count for the new task and clean up old entry
    new_cache_key = f'task_retry_count_{new_task_result.id}'
    cache.set(new_cache_key, retry_count + 1, timeout=86400)  # 24-hour timeout
    cache.delete(cache_key)

[RealOrangeOne]

There's nothing built-in yet. The API and semantics still need a design.

You've already found the related discussion for this, which would be a good place to continued discussion, especially since there's a lot more to discuss right now before anything can really start.