code: def getRunningBatchJobIDs(self):
          
          if (self._getRunningBatchJobIDsTimestamp and (
                  datetime.now() -
                  self._getRunningBatchJobIDsTimestamp).total_seconds() <
                  self.config.statePollingWait):
              batchIds = self._getRunningBatchJobIDsCache
          else:
              batchIds = with_retries(self.worker.getRunningJobIDs)
              self._getRunningBatchJobIDsCache = batchIds
              self._getRunningBatchJobIDsTimestamp = datetime.now()
          batchIds.update(self.getRunningLocalJobIDs())
          return batchIds
docs: Retrieve running job IDs from local and batch scheduler.
  
          Respects statePollingWait and will return cached results if not within
          time period to talk with the scheduler.