En cours de développement

workers/worker.go

@@ -58,7 +58,7 @@ func (w *worker) updateJob(job *jw.Job) {
 			logger.Error( //::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
 				"END",
 				"job", jobID,
-				"workflow", job.Workflow,
+				"workflow", job.WorkflowValue(),
 				nil, err,
 			)
 			return
@@ -68,7 +68,7 @@ func (w *worker) updateJob(job *jw.Job) {
 			logger.Info( //:::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
 				"END",
 				"job", job.ID,
-				"workflow", job.Workflow,
+				"workflow", job.WorkflowValue(),
 				"status", job.Status,
 				"run_after", job.RunAfter.String(),
 				"attempt", fmt.Sprintf("%d/%d", job.Attempt, job.MaxAttempts),
@@ -80,7 +80,7 @@ func (w *worker) updateJob(job *jw.Job) {
 		logger.Info( //:::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
 			"END",
 			"job", job.ID,
-			"workflow", job.Workflow,
+			"workflow", job.WorkflowValue(),
 			"status", job.Status,
 		)
 	}
@@ -93,7 +93,7 @@ func (w *worker) runJob(job *jw.Job) {
 				w.logger.Error( //::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
 					"PANIC ERROR RECOVERED",
 					"job", job.ID,
-					"workflow", job.Workflow,
+					"workflow", job.WorkflowValue(),
 					"data", data,
 					"stack", string(debug.Stack()),
 				)
@@ -108,7 +108,7 @@ func (w *worker) runJob(job *jw.Job) {
 			w.logger.Error( //::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
 				"RUN",
 				"job", job.ID,
-				"workflow", job.Workflow,
+				"workflow", job.WorkflowValue(),
 				nil, err,
 			)
 		}
@@ -136,7 +136,7 @@ func (w *worker) maybeRunJob() time.Duration {
 			"Worker",
 			"id", w.id,
 			"job", job.ID,
-			"workflow", job.Workflow,
+			"workflow", job.WorkflowValue(),
 			"count", count,
 		)
 	}