def METHOD_NAME(self):
    super().METHOD_NAME()
    logger.info(f"STARTED connector: {self.__repr__()}")
    self._config: ConnectorConfig
    if self._job.status not in [
        self._job.Status.REPORTED_WITH_FAILS,
        self._job.Status.REPORTED_WITHOUT_FAILS,
    ]:
        if (
            self._config.run_on_failure
            and self._job.status == self._job.Status.FAILED
        ):
            logger.info(
                f"Running connector {self.__class__.__name__} "
                f"even if job status is {self._job.status} because"
                "run on failure is set"
            )
        else:
            raise ConnectorRunException(
                f"Job status is {self._job.status}, "
                f"unable to run connector {self.__class__.__name__}"
            )