def METHOD_NAME(
    self,
    logger: logging.Logger,
    config: Mapping[str, Any],
    catalog: ConfiguredAirbyteCatalog,
    state: Union[List[AirbyteStateMessage], MutableMapping[str, Any]] = None,
) -> Iterator[AirbyteMessage]:
    """Override to provide filtering of catalog in case if streams were renamed/removed previously"""
    catalog = self._remove_missed_streams_from_catalog(logger, config, catalog)
    return super().METHOD_NAME(logger, config, catalog, state)