from celery.task import task

from custom.icds.data_management.models import DataManagementRequest


@task(queue='background_queue')
def execute_data_management(slug, domain, db_alias, initiated_by, from_date, till_date):
    DataManagementRequest(
        slug, domain, db_alias, initiated_by, from_date, till_date
    ).execute()

from celery.task import task

from custom.icds.data_management.models import DataManagementRequest


@task(queue='background_queue')
def execute_data_management(slug, domain, db_alias, initiated_by, from_date, till_date):
    DataManagementRequest(
        slug=slug, domain=domain, db_alias=db_alias, initiated_by=initiated_by,
        from_date=from_date, till_date=till_date
    ).execute()

fix arg passing