@task(serializer='pickle')
def task_operate_on_payloads(record_ids: List[str], domain: str, action, use_sql: bool):
    return operate_on_payloads(record_ids, domain, action, use_sql, task=task_operate_on_payloads)
@task(serializer='pickle')
def task_operate_on_payloads(record_ids: List[str], domain: str, action, use_sql: bool):
    return operate_on_payloads(record_ids, domain, action, use_sql, task=task_operate_on_payloads)