code: protected void releaseOrphanedTriggers(RedisTriggerState currentState, RedisTriggerState newState, T jedis) throws JobPersistenceException {
          for (Tuple triggerTuple : jedis.zrangeWithScores(redisSchema.triggerStateKey(currentState), 0, -1)) {
              final String lockId = jedis.get(redisSchema.triggerLockKey(redisSchema.triggerKey(triggerTuple.getElement())));
              if(isNullOrEmpty(lockId) || !isActiveInstance(lockId, jedis)){
                  // Lock key has expired. We can safely alter the trigger's state.
                  logger.debug(String.format("Changing state of orphaned trigger %s from %s to %s.", triggerTuple.getElement(), currentState, newState));
                  setTriggerState(newState, triggerTuple.getScore(), triggerTuple.getElement(), jedis);
              }
          }
      }
docs: Release triggers from the given current state to the new state if its locking scheduler has not
  registered as alive in the last 10 minutes
  @param currentState the current state of the orphaned trigger
  @param newState the new state of the orphaned trigger
  @param jedis a thread-safe Redis connection