code: def trigger_chain(self):
          
  
          trigger_stream = self.allocator.attach_stream(self.trigger_stream)
          return (trigger_stream, self.trigger_cond)
docs: Return a NodeInput tuple for creating a node.
  
          Returns:
              (StreamIdentifier, InputTrigger)