def METHOD_NAME(
    self, config: Mapping[str, Any], configured_catalog_path: str, input_stream: io.TextIOWrapper
) -> Iterable[AirbyteMessage]:
    catalog = ConfiguredAirbyteCatalog.parse_file(configured_catalog_path)
    input_messages = self._parse_input_stream(input_stream)
    logger.info("Begin writing to the destination...")
    yield from self.write(config=config, configured_catalog=catalog, input_messages=input_messages)
    logger.info("Writing complete.")