fix(api): check for nil pointer while deserializing duration proto

raystack · Jun 14, 2021 · 1111b1d · 1111b1d
1 parent 042f44c
commit 1111b1d
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/api/handler/v1/adapter.go b/api/handler/v1/adapter.go
@@ -70,6 +70,10 @@ func (adapt *Adapter) FromJobProto(spec *pb.JobSpecification) (models.JobSpec, e
 		})
 	}
 
+	retryDelay := time.Duration(0)
+	if spec.Behavior.Retry.Delay != nil && spec.Behavior.Retry.Delay.IsValid() {
+		retryDelay = spec.Behavior.Retry.Delay.AsDuration()
+	}
 	return models.JobSpec{
 		Version:     int(spec.Version),
 		Name:        spec.Name,
@@ -87,7 +91,7 @@ func (adapt *Adapter) FromJobProto(spec *pb.JobSpecification) (models.JobSpec, e
 			CatchUp:       spec.CatchUp,
 			Retry: models.JobSpecBehaviorRetry{
 				Count:              int(spec.Behavior.Retry.Count),
-				Delay:              spec.Behavior.Retry.Delay.AsDuration(),
+				Delay:              retryDelay,
 				ExponentialBackoff: spec.Behavior.Retry.ExponentialBackoff,
 			},
 		},