Cancel pending clock tasks

iotaledger · Oct 18, 2023 · b60fb44 · b60fb44
1 parent 4f9273e
commit b60fb44
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/protocol/engine/clock/blocktime/clock.go b/pkg/protocol/engine/clock/blocktime/clock.go
@@ -38,7 +38,7 @@ func NewProvider(opts ...options.Option[Clock]) module.Provider[*engine.Engine,
 		return options.Apply(&Clock{
 			acceptedTime:  NewRelativeTime(),
 			confirmedTime: NewRelativeTime(),
-			workerPool:    e.Workers.CreatePool("Clock", workerpool.WithWorkerCount(1)),
+			workerPool:    e.Workers.CreatePool("Clock", workerpool.WithWorkerCount(1), workerpool.WithCancelPendingTasksOnShutdown(true)),
 		}, opts, func(c *Clock) {
 			e.HookConstructed(func() {
 				latestCommitmentIndex := e.Storage.Settings().LatestCommitment().Slot()