fix: set default timeout of 15 minutes

camunda · Oct 12, 2022 · e8263eb · e8263eb
1 parent 272f74f
commit e8263eb
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/go-chaos/cmd/worker.go b/go-chaos/cmd/worker.go
@@ -63,15 +63,20 @@ func start_worker(cmd *cobra.Command, args []string) {
 func handleZbChaosJob(client worker.JobClient, job entities.Job) {
 	ctx := context.Background()
 
-	var jobVariables ZbChaosVariables
+    jobVariables := ZbChaosVariables {
+        provider: ChaosProvider {
+            timeout: 15 * 60, // 15 minute default timeout
+        },
+    }
 	err := job.GetVariablesAs(&jobVariables)
 	if err != nil {
 		// Can't parse variables, no sense in retrying
 		_, _ = client.NewFailJobCommand().JobKey(job.Key).Retries(0).Send(ctx)
 		return
 	}
 
-	commandCtx, cancelCommand := context.WithTimeout(ctx, time.Duration(jobVariables.provider.timeout)*time.Second)
+    timeout := time.Duration(jobVariables.provider.timeout) * time.Second
+	commandCtx, cancelCommand := context.WithTimeout(ctx, timeout)
 	defer cancelCommand()
 
 	err = runZbChaosCommand(jobVariables.provider.args, commandCtx)