original_docstring: On consumer failure event handler.
docstring: On consumer failure event handler.
docstring_tokens: On consumer failure event handler .
code: def on_consumer_failure(self, input_msg, exception):
          """On consumer failure event handler."""
          self._failures_total.inc()
  
          if self._downloaded_time is None:
              self._download_duration.observe(time.time() - self._start_time)
              self._process_duration.observe(0)
          elif self._processed_time is None:
              self._process_duration.observe(time.time() - self._downloaded_time)
  
          self._publish_duration.observe(0)
code_tokens: def on_consumer_failure ( self , input_msg , exception ) : self . _failures_total . inc ( ) if self . _downloaded_time is None : self . _download_duration . observe ( time . time ( ) - self . _start_time ) self . _process_duration . observe ( 0 ) elif self . _processed_time is None : self . _process_duration . observe ( time . time ( ) - self . _downloaded_time ) self . _publish_duration . observe ( 0 )
short_docstring: On consumer failure event handler.
short_docstring_tokens: On consumer failure event handler .
comment: """On consumer failure event handler."""