def METHOD_NAME(self):
    ds3 = DataSourceConfiguration.wrap(get_sample_data_source().to_json())
    ds3.engine_id = DEFAULT_ENGINE_ID
    ds3.mirrored_engine_ids = ['engine-2']
    adapter = get_indicator_adapter(ds3)
    self.assertEqual(type(adapter.adapter), MultiDBSqlAdapter)
    self.assertEqual(len(adapter.all_adapters), 2)
    for db_adapter in adapter.all_adapters:
        with db_adapter.session_context() as session:
            self.assertEqual(0, session.query(db_adapter.get_table()).count())
    with (
        patch('pillowtop.models.KafkaCheckpoint.get_or_create_for_checkpoint_id'),
        patch('corehq.apps.userreports.pillow_utils._is_datasource_active', return_value=True)
    ):
        pillow = get_case_pillow(ucr_configs=[ds3])
    sample_doc, _ = get_sample_doc_and_indicators()
    pillow.process_change(doc_to_change(sample_doc))
    for db_adapter in adapter.all_adapters:
        with db_adapter.session_context() as session:
            self.assertEqual(1, session.query(db_adapter.get_table()).count())