Produits Entr'ouvert » Passerelle

Pour la même chose coté zoo je prends la peine de locker les jobs, si on peut se permettre de n'être compatible que Django 1.11 désormais on peut faire :

while True:
    with atomic():
        # lock a job
        job = Job.objects.filter(..., status='registered').select_for_update(skip_locked=True)[:1].first()
        if not job:
            break
        job.status = 'running'
        job.save()
        # release lock
    try:
        getattr(self, job.method_name)(**job.parameters)
        job.status = 'completed'
    except SkipJob:
        job.status = 'registered'
    except Exception as e:
        (exc_type, exc_value, tb) = sys.exc_info()
        job.status = 'failed'
        job.done_timestamp = timezone.now()
        job.status_details = {
            'error_summary': '\n'.join(traceback.format_exception_only(exc_type, exc_value)).strip(),
        }
    job.save()

Si on veut être compatible Django 1.8, on ne peut utiliser que nowait=True et pas skip_locked=Trye et donc il faut boucler et récupérer DatabaseError.

Aussi ça peut être intéressant d'avoir un identifiant sur un job pour l'associer à un truc qu'on voudrait retrouver plus tard, genre pour remonter au workflow qu'un job à foirer, le relancer ou que sais-je (un simple job_id = models.CharField(max_length=256, blank=True, null=True)).

À part ça c'est ack pour moi.