(
    pillow_id='kafka-ucr-registry',
    num_processes=1, process_num=0, dedicated_migration_process=False,
    processor_chunk_size=DEFAULT_PROCESSOR_CHUNK_SIZE, ucr_configs=None, **kwargs)
return ConfigurableReportKafkaPillow(
        processor=ucr_processor,
        pillow_name=pillow_id,
        topics=CASE_TOPICS,
        num_processes=num_processes,
        process_num=process_num,
        is_dedicated_migration_process=dedicated_migration_process and (process_num == 0),
        processor_chunk_size=processor_chunk_size,
    )
UCR pillow that reads from all 'case' Kafka topics and writes data into the UCR database tables

    Only UCRs backed by Data Registries are processed in this pillow.

        Processors:
          - :py:class:`corehq.apps.userreports.pillow.ConfigurableReportPillowProcessor`
UCR pillow that reads from all 'case' Kafka topics and writes data into the UCR database tables
UCR pillow that reads from all case Kafka topics and writes data into the UCR database tables
def get_kafka_ucr_registry_pillow(
    pillow_id='kafka-ucr-registry',
    num_processes=1, process_num=0, dedicated_migration_process=False,
    processor_chunk_size=DEFAULT_PROCESSOR_CHUNK_SIZE, ucr_configs=None, **kwargs):
    """UCR pillow that reads from all 'case' Kafka topics and writes data into the UCR database tables

    Only UCRs backed by Data Registries are processed in this pillow.

        Processors:
          - :py:class:`corehq.apps.userreports.pillow.ConfigurableReportPillowProcessor`
    """
    ucr_processor = get_data_registry_ucr_processor(
        run_migrations=(process_num == 0),  # only first process runs migrations
        ucr_configs=ucr_configs
    )

    return ConfigurableReportKafkaPillow(
        processor=ucr_processor,
        pillow_name=pillow_id,
        topics=CASE_TOPICS,
        num_processes=num_processes,
        process_num=process_num,
        is_dedicated_migration_process=dedicated_migration_process and (process_num == 0),
        processor_chunk_size=processor_chunk_size,
    )
def get_kafka_ucr_registry_pillow ( pillow_id = 'kafka-ucr-registry' , num_processes = 1 , process_num = 0 , dedicated_migration_process = False , processor_chunk_size = DEFAULT_PROCESSOR_CHUNK_SIZE , ucr_configs = None , * * kwargs ) : ucr_processor = get_data_registry_ucr_processor ( run_migrations = ( process_num == 0 ) , # only first process runs migrations ucr_configs = ucr_configs ) return ConfigurableReportKafkaPillow ( processor = ucr_processor , pillow_name = pillow_id , topics = CASE_TOPICS , num_processes = num_processes , process_num = process_num , is_dedicated_migration_process = dedicated_migration_process and ( process_num == 0 ) , processor_chunk_size = processor_chunk_size , )