I have a model that looks something like this:
Job(models.Model):
status = models.CharField(max_length=8, choices = statuses)
jobid = models.CharField(max_length=20, db_index=True)
...
I submit tasks to celery. The task fetches the Job object, changes its
status to RUNNING, does the computation, then changes the status to
FINISHED. If the job crashes in my code I can catch the exception, set the
status to ERROR and act accordingly, but if it crashes for some other
reason I won't know it. The only thing I can think of is to stop the
celery queue, let it drain, and check the Job table for objects set to
RUNNING. Seems janky to me. Is there a better way?
--
You received this message because you are subscribed to the Google Groups
"Django users" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/django-users.
To view this discussion on the web visit
https://groups.google.com/d/msgid/django-users/aebae6cf-de7f-4920-8731-9ce8cfd0922e%40googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.
