original_docstring: On consumer success event handler.
docstring: On consumer success event handler.
docstring_tokens: On consumer success event handler .
code: def on_consumer_success(self, input_msg, broker, results):
          """On consumer success event handler."""
          self._published_total.inc()
  
          self._published_time = time.time()
          self._publish_duration.observe(self._published_time - self._processed_time)
code_tokens: def on_consumer_success ( self , input_msg , broker , results ) : self . _published_total . inc ( ) self . _published_time = time . time ( ) self . _publish_duration . observe ( self . _published_time - self . _processed_time )
short_docstring: On consumer success event handler.
short_docstring_tokens: On consumer success event handler .
comment: """On consumer success event handler."""