def METHOD_NAME(self) -> None:
    logger.info("starting %s", self.name)
    while True:
        try:
            self._collector.collect(self._config.stream.outputs.merged)
        except Exception as exception:  # pylint: disable=broad-exception-caught
            logger.exception(exception)
        sleep(120)