rq_tasks.py

from django_rq import job


@job
def refresh_cache(klass_str, obj_args, obj_kwargs, call_args, call_kwargs):
    from .base import Job

    Job.perform_async_refresh(klass_str, obj_args, obj_kwargs, call_args, call_kwargs)