Fix exceptions
This commit is contained in:
parent
0e224c1667
commit
d5262c80e8
@ -4,6 +4,7 @@ import json
|
|||||||
from celery import Celery, Task
|
from celery import Celery, Task
|
||||||
from celery.schedules import crontab
|
from celery.schedules import crontab
|
||||||
from celery.utils.log import get_task_logger
|
from celery.utils.log import get_task_logger
|
||||||
|
from celery.exceptions import MaxRetriesExceededError
|
||||||
import time as time_
|
import time as time_
|
||||||
|
|
||||||
|
|
||||||
@ -215,7 +216,7 @@ def run_recurrent_import(self, pk):
|
|||||||
try:
|
try:
|
||||||
# if chromium is locked, we wait before retrying
|
# if chromium is locked, we wait before retrying
|
||||||
raise self.retry(countdown=120)
|
raise self.retry(countdown=120)
|
||||||
except celery.exceptions.MaxRetriesExceededError as e:
|
except MaxRetriesExceededError as e:
|
||||||
logger.error(e)
|
logger.error(e)
|
||||||
close_import_task(req_id, False, e, importer)
|
close_import_task(req_id, False, e, importer)
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user