(pillow_id='FormSubmissionMetadataTrackerPillow',
                                                num_processes=1, process_num=0, **kwargs)
return ConstructedPillow(
        name=pillow_id,
        checkpoint=checkpoint,
        change_feed=change_feed,
        processor=form_processor,
        change_processed_event_handler=KafkaCheckpointEventHandler(
            checkpoint=checkpoint, checkpoint_frequency=100, change_feed=change_feed,
        ),
    )
This gets a pillow which iterates through all forms and marks the corresponding app
    as having submissions.

        Processors:
          - :py:class:`pillowtop.processors.form.FormSubmissionMetadataTrackerProcessor`
This gets a pillow which iterates through all forms and marks the corresponding app
    as having submissions.
This gets a pillow which iterates through all forms and marks the corresponding app as having submissions .
def get_form_submission_metadata_tracker_pillow(pillow_id='FormSubmissionMetadataTrackerPillow',
                                                num_processes=1, process_num=0, **kwargs):
    """
    This gets a pillow which iterates through all forms and marks the corresponding app
    as having submissions.

        Processors:
          - :py:class:`pillowtop.processors.form.FormSubmissionMetadataTrackerProcessor`
    """
    # todo; To remove after full rollout of https://github.com/dimagi/commcare-hq/pull/21329/
    change_feed = KafkaChangeFeed(
        topics=topics.FORM_TOPICS, client_id='form-processsor',
        num_processes=num_processes, process_num=process_num
    )
    checkpoint = KafkaPillowCheckpoint('form-submission-metadata-tracker', topics.FORM_TOPICS)
    form_processor = FormSubmissionMetadataTrackerProcessor()
    return ConstructedPillow(
        name=pillow_id,
        checkpoint=checkpoint,
        change_feed=change_feed,
        processor=form_processor,
        change_processed_event_handler=KafkaCheckpointEventHandler(
            checkpoint=checkpoint, checkpoint_frequency=100, change_feed=change_feed,
        ),
    )
def get_form_submission_metadata_tracker_pillow ( pillow_id = 'FormSubmissionMetadataTrackerPillow' , num_processes = 1 , process_num = 0 , * * kwargs ) : # todo; To remove after full rollout of https://github.com/dimagi/commcare-hq/pull/21329/ change_feed = KafkaChangeFeed ( topics = topics . FORM_TOPICS , client_id = 'form-processsor' , num_processes = num_processes , process_num = process_num ) checkpoint = KafkaPillowCheckpoint ( 'form-submission-metadata-tracker' , topics . FORM_TOPICS ) form_processor = FormSubmissionMetadataTrackerProcessor ( ) return ConstructedPillow ( name = pillow_id , checkpoint = checkpoint , change_feed = change_feed , processor = form_processor , change_processed_event_handler = KafkaCheckpointEventHandler ( checkpoint = checkpoint , checkpoint_frequency = 100 , change_feed = change_feed , ) , )