41 lines
994 B
Python
41 lines
994 B
Python
import functools
|
|
import os
|
|
|
|
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'application.settings')
|
|
|
|
from django.conf import settings
|
|
from celery import platforms
|
|
|
|
# 租户模式
|
|
if "django_tenants" in settings.INSTALLED_APPS:
|
|
from tenant_schemas_celery.app import CeleryApp as TenantAwareCeleryApp
|
|
|
|
app = TenantAwareCeleryApp()
|
|
else:
|
|
from celery import Celery
|
|
|
|
app = Celery(f"application")
|
|
app.config_from_object('django.conf:settings', namespace='CELERY')
|
|
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
|
|
platforms.C_FORCE_ROOT = True
|
|
|
|
|
|
def retry_base_task_error():
|
|
"""
|
|
celery 失败重试装饰器
|
|
:return:
|
|
"""
|
|
|
|
def wraps(func):
|
|
@app.task(bind=True, retry_delay=180, max_retries=3)
|
|
@functools.wraps(func)
|
|
def wrapper(self, *args, **kwargs):
|
|
try:
|
|
return func(*args, **kwargs)
|
|
except Exception as exc:
|
|
raise self.retry(exc=exc)
|
|
|
|
return wrapper
|
|
|
|
return wraps
|