code: def process_streamers(self):
          
  
          # Check for any triggered streamers and pass them to stream manager
          in_progress = self._stream_manager.in_progress()
          triggered = self.graph.check_streamers(blacklist=in_progress)
  
          for streamer in triggered:
              self._stream_manager.process_streamer(streamer, callback=self._handle_streamer_finished)
docs: Check if any streamers should be handed to the stream manager.