catch the new ProcessUpdatesAlreadyRunning exception
This commit is contained in:
parent
d554a98985
commit
0b3517de5b
1 changed files with 1 additions and 2 deletions
|
@ -1,7 +1,6 @@
|
||||||
import logging
|
import logging
|
||||||
|
|
||||||
from celery.exceptions import MaxRetriesExceededError
|
from celery.exceptions import MaxRetriesExceededError
|
||||||
from django.db import DatabaseError
|
|
||||||
from django.utils.formats import date_format
|
from django.utils.formats import date_format
|
||||||
from django.utils.translation import ugettext_lazy as _
|
from django.utils.translation import ugettext_lazy as _
|
||||||
from django.utils.translation import ungettext_lazy
|
from django.utils.translation import ungettext_lazy
|
||||||
|
@ -22,7 +21,7 @@ def process_map_updates(self):
|
||||||
try:
|
try:
|
||||||
try:
|
try:
|
||||||
updates = MapUpdate.process_updates()
|
updates = MapUpdate.process_updates()
|
||||||
except DatabaseError:
|
except MapUpdate.ProcessUpdatesAlreadyRunning:
|
||||||
if self.request.called_directly:
|
if self.request.called_directly:
|
||||||
raise
|
raise
|
||||||
logger.info('Processing is already running, retrying in 30 seconds.')
|
logger.info('Processing is already running, retrying in 30 seconds.')
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue