(pillow_id='group-pillow', num_processes=1, process_num=0, **kwargs)
return ConstructedPillow(
        name=pillow_id,
        checkpoint=checkpoint,
        change_feed=change_feed,
        processor=[to_user_es_processor, to_group_es_processor],
        change_processed_event_handler=KafkaCheckpointEventHandler(
            checkpoint=checkpoint, checkpoint_frequency=10, change_feed=change_feed
        ),
    )
Group pillow

    Processors:
      - :py:class:`corehq.pillows.groups_to_user.GroupsToUsersProcessor`
      - :py:func:`corehq.pillows.group.get_group_to_elasticsearch_processor`
Group pillow
Group pillow
def get_group_pillow(pillow_id='group-pillow', num_processes=1, process_num=0, **kwargs):
    """Group pillow

    Processors:
      - :py:class:`corehq.pillows.groups_to_user.GroupsToUsersProcessor`
      - :py:func:`corehq.pillows.group.get_group_to_elasticsearch_processor`
    """
    assert pillow_id == 'group-pillow', 'Pillow ID is not allowed to change'
    to_user_es_processor = GroupsToUsersProcessor()
    to_group_es_processor = get_group_to_elasticsearch_processor()
    change_feed = KafkaChangeFeed(
        topics=[topics.GROUP], client_id='groups-to-users', num_processes=num_processes, process_num=process_num
    )
    checkpoint_id = "{}-{}-{}".format(
        pillow_id, USER_INDEX, to_group_es_processor.index_info.index)
    checkpoint = KafkaPillowCheckpoint(checkpoint_id, [topics.GROUP])
    return ConstructedPillow(
        name=pillow_id,
        checkpoint=checkpoint,
        change_feed=change_feed,
        processor=[to_user_es_processor, to_group_es_processor],
        change_processed_event_handler=KafkaCheckpointEventHandler(
            checkpoint=checkpoint, checkpoint_frequency=10, change_feed=change_feed
        ),
    )
def get_group_pillow ( pillow_id = 'group-pillow' , num_processes = 1 , process_num = 0 , * * kwargs ) : assert pillow_id == 'group-pillow' , 'Pillow ID is not allowed to change' to_user_es_processor = GroupsToUsersProcessor ( ) to_group_es_processor = get_group_to_elasticsearch_processor ( ) change_feed = KafkaChangeFeed ( topics = [ topics . GROUP ] , client_id = 'groups-to-users' , num_processes = num_processes , process_num = process_num ) checkpoint_id = "{}-{}-{}" . format ( pillow_id , USER_INDEX , to_group_es_processor . index_info . index ) checkpoint = KafkaPillowCheckpoint ( checkpoint_id , [ topics . GROUP ] ) return ConstructedPillow ( name = pillow_id , checkpoint = checkpoint , change_feed = change_feed , processor = [ to_user_es_processor , to_group_es_processor ] , change_processed_event_handler = KafkaCheckpointEventHandler ( checkpoint = checkpoint , checkpoint_frequency = 10 , change_feed = change_feed ) , )