try:

            result = await self.call_func(self.first_run, call_kwargs)

            self.lastSuccessRun = time.time()

            if self.fps:

                self.fps.mark()

            self.up_metric.set(1)

            self.everSucceeded = True

            self.newlyFailing = True

            self.first_run = False

        except Exception as ex:

            if self.newlyFailing:

                traceback.print_exc()

                self.newlyFailing = False

            else:

                log.error(ex)

            self.up_metric.set(0)

            result = None

            self.succeeding = False

            await asyncio.sleep(self.extra_sleep_on_error)

            # todo: something that reveals error ratio

        return result

    def _updateFps(self, now: float):

        if self.fps is None:

            return

        if now < self.lastFpsLog + 5:

            return

        d = self.fps()

        y_hi = 1 / self.sleep_period

        if not d:

            return

        pts = [int(min(4, y / y_hi * 4)) for y in d['recents']]

        log.info(f'{self.metric_prefix} fps={d["average"]:3.1f} (req={y_hi:3.1f}) {horizontal_graph(pts)}')

        self.lastFpsLog = now

def loop_forever(

    func: UserFunc,

    sleep_period: float,

    metric_prefix='background_loop',

    up_metric=None,

    call_metric=None,

    extra_sleep_on_error=2,

    log_fps=False,

):

    """

    sleep_period is the sleep time after however long func takes to run