23 lines
548 B
Python
23 lines
548 B
Python
import os
|
|
|
|
from celery import Celery
|
|
|
|
|
|
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "airshelf.settings.development")
|
|
|
|
app = Celery("airshelf")
|
|
app.config_from_object("django.conf:settings", namespace="CELERY")
|
|
app.autodiscover_tasks()
|
|
|
|
|
|
from celery.signals import worker_ready # noqa: E402
|
|
|
|
|
|
@worker_ready.connect
|
|
def _kick_asset_review_drain(**kwargs):
|
|
"""Worker 起来就自动转人脸审核,不用人去后台点送审。"""
|
|
from apps.ai.tasks import drain_asset_reviews_task
|
|
|
|
drain_asset_reviews_task.apply_async(countdown=8)
|
|
|