()
return CaseSearchPillowProcessor(
        elasticsearch=get_es_new(),
        index_info=CASE_SEARCH_INDEX_INFO,
        doc_prep_fn=transform_case_for_elasticsearch,
        change_filter_fn=is_couch_change_for_sql_domain
    )
Case Search

    Reads from:
      - Case data source

    Writes to:
      - Case Search ES index
Case Search
Case Search
def get_case_search_processor():
    """Case Search

    Reads from:
      - Case data source

    Writes to:
      - Case Search ES index
    """
    return CaseSearchPillowProcessor(
        elasticsearch=get_es_new(),
        index_info=CASE_SEARCH_INDEX_INFO,
        doc_prep_fn=transform_case_for_elasticsearch,
        change_filter_fn=is_couch_change_for_sql_domain
    )
def get_case_search_processor ( ) : return CaseSearchPillowProcessor ( elasticsearch = get_es_new ( ) , index_info = CASE_SEARCH_INDEX_INFO , doc_prep_fn = transform_case_for_elasticsearch , change_filter_fn = is_couch_change_for_sql_domain )