1diff --git a/pkg/worker/worker.go b/pkg/worker/worker.go
2index b768320465871193d203467657b48372e7d2a0ba..454716651ae13ed05db23317c496b1b87027c668 100644
3--- a/pkg/worker/worker.go
4+++ b/pkg/worker/worker.go
5@@ -25,6 +25,10 @@ tasks []*Work
6 }
7 )
8
9+const (
10+ format = "2006.01.02 15:04:05"
11+)
12+
13 func NewTaskPool() *TaskPool {
14 return &TaskPool{}
15 }
16@@ -38,12 +42,15 @@ select {
17 case <-ctx.Done():
18 return ctx.Err()
19 case <-timer.C:
20- fmt.Println("Process starting: ", w.Name)
21+ now := time.Now()
22+ fmt.Printf("[%s] Process starting: %s\n", time.Now().Format(format), w.Name)
23 if err := w.Task.Start(ctx); err != nil && !errors.Is(err, context.Canceled) {
24- fmt.Println("Process errored: ", w.Name, err.Error())
25+ since := time.Since(now)
26+ fmt.Printf("[%s] Process errored (%s): %s\n", time.Now().Format(format), since.String(), w.Name)
27 return err
28 } else {
29- fmt.Println("Process done: ", w.Name)
30+ since := time.Since(now)
31+ fmt.Printf("[%s] Process done (%s): %s\n", time.Now().Format(format), since.String(), w.Name)
32 }
33 }
34 timer.Reset(w.wait)