def METHOD_NAME(self):
    state = AirbyteStateMessage(data={})
    list(self.integration._load_data("test2", state))
    self.source.read.assert_called_once_with(
        self.config,
        ConfiguredAirbyteCatalog(
            streams=[
                ConfiguredAirbyteStream(
                    stream=self.stream2,
                    sync_mode=SyncMode.full_refresh,
                    destination_sync_mode=DestinationSyncMode.append,
                )
            ]
        ),
        state,
    )