tasks.py

from celery import shared_task
from engine.rpc import get_current_rpc_invoker