code: async def _reset_vector(self):
          
  
          self._logger.debug("sensor_graph subsystem task starting")
  
          # If there is a persistent sgf loaded, send reset information.
  
          self.initialized.set()
  
          while True:
              stream, reading = await self._inputs.get()
  
              try:
                  await process_graph_input(self.graph, stream, reading, self._executor)
                  self.process_streamers()
              except:  #pylint:disable=bare-except;This is a background task that should not die
                  self._logger.exception("Unhandled exception processing sensor_graph input (stream=%s), reading=%s", stream, reading)
              finally:
                  self._inputs.task_done()
docs: Background task to initialize this system in the event loop.