Rename key

Author: cschleiden

backend/redis/instance.go

@@ -160,7 +160,7 @@ func createInstanceP(ctx context.Context, p redis.Pipeliner, instance *core.Work
 		Score:  float64(createdAt.UnixMilli()),
 	})
 
-	p.SAdd(ctx, activeInstances(), instanceSegment(instance))
+	p.SAdd(ctx, instancesActive(), instanceSegment(instance))
 
 	return nil
 }
@@ -176,7 +176,7 @@ func updateInstanceP(ctx context.Context, p redis.Pipeliner, instance *core.Work
 	p.Set(ctx, key, string(b), 0)
 
 	if state.State != core.WorkflowInstanceStateActive {
-		p.SRem(ctx, activeInstances(), instanceSegment(instance))
+		p.SRem(ctx, instancesActive(), instanceSegment(instance))
 	}
 
 	// CreatedAt does not change, so skip updating the instancesByCreation() ZSET

backend/redis/keys.go

@@ -29,8 +29,8 @@ func instancesByCreation() string {
 	return "instances-by-creation"
 }
 
-func activeInstances() string {
-	return "active-instances"
+func instancesActive() string {
+	return "instances-active"
 }
 
 func instancesExpiring() string {

backend/redis/stats.go

@@ -13,7 +13,7 @@ func (rb *redisBackend) GetStats(ctx context.Context) (*backend.Stats, error) {
 	s := &backend.Stats{}
 
 	// get workflow instances
-	activeInstances, err := rb.rdb.SCard(ctx, activeInstances()).Result()
+	activeInstances, err := rb.rdb.SCard(ctx, instancesActive()).Result()
 	if err != nil {
 		return nil, fmt.Errorf("getting active instances: %w", err)
 	}