from celery import shared_task
from engine.rpc import get_current_rpc_invoker