(
        pillow_id='UpdateUserSyncHistoryPillow', num_processes=1, process_num=0, **kwargs)
return ConstructedPillow(
        name=pillow_id,
        checkpoint=checkpoint,
        change_feed=change_feed,
        processor=UserSyncHistoryProcessor(),
        change_processed_event_handler=KafkaCheckpointEventHandler(
            checkpoint=checkpoint, checkpoint_frequency=100, change_feed=change_feed
        ),
    )
Synclog pillow

    Processors:
      - :py:func:`corehq.pillows.synclog.UserSyncHistoryProcessor`
Synclog pillow
Synclog pillow
def get_user_sync_history_pillow(
        pillow_id='UpdateUserSyncHistoryPillow', num_processes=1, process_num=0, **kwargs):
    """Synclog pillow

    Processors:
      - :py:func:`corehq.pillows.synclog.UserSyncHistoryProcessor`
    """
    change_feed = KafkaChangeFeed(
        topics=[topics.SYNCLOG_SQL], client_id=SYNCLOG_SQL_USER_SYNC_GROUP_ID,
        num_processes=num_processes, process_num=process_num)
    checkpoint = KafkaPillowCheckpoint(pillow_id, [topics.SYNCLOG_SQL])
    return ConstructedPillow(
        name=pillow_id,
        checkpoint=checkpoint,
        change_feed=change_feed,
        processor=UserSyncHistoryProcessor(),
        change_processed_event_handler=KafkaCheckpointEventHandler(
            checkpoint=checkpoint, checkpoint_frequency=100, change_feed=change_feed
        ),
    )
def get_user_sync_history_pillow ( pillow_id = 'UpdateUserSyncHistoryPillow' , num_processes = 1 , process_num = 0 , * * kwargs ) : change_feed = KafkaChangeFeed ( topics = [ topics . SYNCLOG_SQL ] , client_id = SYNCLOG_SQL_USER_SYNC_GROUP_ID , num_processes = num_processes , process_num = process_num ) checkpoint = KafkaPillowCheckpoint ( pillow_id , [ topics . SYNCLOG_SQL ] ) return ConstructedPillow ( name = pillow_id , checkpoint = checkpoint , change_feed = change_feed , processor = UserSyncHistoryProcessor ( ) , change_processed_event_handler = KafkaCheckpointEventHandler ( checkpoint = checkpoint , checkpoint_frequency = 100 , change_feed = change_feed ) , )