def run(self, stat):
    if ((self._axis._streaming_thread is None) or self._axis._streaming_thread.is_paused()):
        stat.summary(DiagnosticStatusWrapper.OK, 'Video not subscribed')
    else:
        stat = DiagnosedPublisher.run(self, stat)
    return stat
def run(self, stat):
    if ((self._axis._streaming_thread is None) or self._axis._streaming_thread.is_paused()):
        stat.summary(DiagnosticStatusWrapper.OK, 'Video not subscribed')
    else:
        stat = DiagnosedPublisher.run(self, stat)
    return stat