def METHOD_NAME(self, input_buffer) -> None:
    try:
        if self.to_df:
            self.transform_input(input_buffer)
        else:
            catalog = self.catalog or self.discover(streams=self.selected_streams)
            dtypes = {
                k: dict(type=['null', convert_data_type(v)])
                for k, v in infer_dtypes(self.df).items()
            }
            self.sync(catalog, dtypes)
    except Exception as err:
        message = f'{self.__class__.__name__} process failed with error {str(err)}.'
        self.logger.exception(message, tags=dict(
            error=str(err),
            errors=traceback.format_stack(),
            message=traceback.format_exc(),
        ))
        raise Exception(message)