docs: def get_consumer_process(self, consumer, name):
          """Get the process object for the specified consumer and process name.
  
          :param str consumer: The consumer name
          :param str name: The process name
          :returns: multiprocessing.Process
  
          """
          return self.consumers[consumer].processes.get(name)