@task(serializer='pickle')
def task_generate_ids_and_operate_on_payloads(payload_id: Optional[str], repeater_id: Optional[str], domain: str, action, use_sql: bool) -> dict:
    repeat_record_ids = _get_repeat_record_ids(payload_id, repeater_id, domain, use_sql)
    return operate_on_payloads(repeat_record_ids, domain, action, use_sql, task=task_generate_ids_and_operate_on_payloads)
@task(serializer='pickle')
def task_generate_ids_and_operate_on_payloads(payload_id: Optional[str], repeater_id: Optional[str], domain: str, action, use_sql: bool) -> dict:
    repeat_record_ids = _get_repeat_record_ids(payload_id, repeater_id, domain, use_sql)
    return operate_on_payloads(repeat_record_ids, domain, action, use_sql, task=task_generate_ids_and_operate_on_payloads)