add TTL for the task locks

docs/configuration_syntax.md

@@ -60,6 +60,18 @@ redis:
   # environment variable)
   url: redis://foo:bar@redis.example.net:6379
 
+  # TTL for the project locks
+  project_ttl: 168h
+
+  # TTL for the ref locks
+  ref_ttl: 1h
+
+  # TTL for the metric locks
+  metric_ttl: 1h
+
+  # TTL for the task locks
+  task_ttl: 30m
+
 # URL and Token with sufficient permissions to access
 # your GitLab's projects pipelines informations (optional)
 gitlab:

pkg/config/config.go

@@ -136,6 +136,7 @@ type Redis struct {
 	ProjectTTL time.Duration `default:"168h" yaml:"project_ttl"`
 	RefTTL     time.Duration `default:"1h" yaml:"ref_ttl"`
 	MetricTTL  time.Duration `default:"1h" yaml:"metric_ttl"`
+	TaskTTL    time.Duration `default:"0" yaml:"task_ttl"`
 }
 
 // Pull ..

pkg/controller/controller.go

@@ -60,6 +60,7 @@ func New(ctx context.Context, cfg config.Config, version string) (c Controller,
 			Project: cfg.Redis.ProjectTTL,
 			Ref:     cfg.Redis.RefTTL,
 			Metric:  cfg.Redis.MetricTTL,
+			Task:    cfg.Redis.TaskTTL,
 		}))
 	}
 

pkg/store/redis.go

@@ -40,6 +40,7 @@ type RedisTTLConfig struct {
 	Project time.Duration
 	Ref     time.Duration
 	Metric  time.Duration
+	Task    time.Duration
 }
 
 func WithTTLConfig(opt *RedisTTLConfig) func(*RedisStoreConfig) {
@@ -464,7 +465,7 @@ func (r *Redis) QueueTask(ctx context.Context, tt schemas.TaskType, taskUUID, pr
 	k := getRedisQueueKey(tt, taskUUID)
 
 	// We attempt to set the key, if it already exists, we do not overwrite it
-	set, err = r.SetNX(ctx, k, processUUID, 0).Result()
+	set, err = r.SetNX(ctx, k, processUUID, r.StoreConfig.TTLConfig.Task).Result()
 	if err != nil || set {
 		return
 	}
@@ -487,7 +488,7 @@ func (r *Redis) QueueTask(ctx context.Context, tt schemas.TaskType, taskUUID, pr
 		}
 
 		if !uuidIsAlive {
-			if _, err = r.Set(ctx, k, processUUID, 0).Result(); err != nil {
+			if _, err = r.Set(ctx, k, processUUID, r.StoreConfig.TTLConfig.Task).Result(); err != nil {
 				return
 			}