code: def go(self, poller_configurations):
          
          try:
              notify(
                  CachableSourcePollersAboutToStartEvent(poller_configurations))
              logger.info("Starting pollers")
              exit_ = threading.Event()
              for config in poller_configurations: # config is a dict
                  kwargs = {'exit_': exit_}
                  kwargs.update(config)
                  threading.Thread(target=self.poll, 
                                          kwargs=(kwargs), 
                                      ).start()
              while threading.active_count() > 1:
                  time.sleep(.001)
          except KeyboardInterrupt:
              logger.info("KeyboardInterrupt signal caught, shutting down pollers...")
              exit_.set()
docs: Create threaded pollers and start configured polling cycles