code: def run(self, *, delay=None):
          
          self.broker.enqueue(self.messages[0], delay=delay)
          return self
docs: Run this pipeline.
  
          Parameters:
            delay(int): The minimum amount of time, in milliseconds, the
              pipeline should be delayed by.
  
          Returns:
            pipeline: Itself.