diff --git a/engine.go b/engine.go
index aa0a37c..8daf863 100644
--- a/engine.go
+++ b/engine.go
@@ -7,22 +7,22 @@ import (
 	"log"
 	"log/slog"
 	"sync"
-	"sync/atomic"
 )
 
 var ErrFlowNotFound = errors.New("flow not found")
-var execIDS = &atomic.Int64{}
 
 type Engine struct {
 	d Doer
+	l *slog.Logger
 
 	wg     *sync.WaitGroup
 	doneCh chan struct{}
 }
 
-func NewEngine(d Doer) (*Engine, error) {
+func NewEngine(d Doer, l *slog.Logger) (*Engine, error) {
 	e := &Engine{
 		d: d,
+		l: l,
 
 		wg:     &sync.WaitGroup{},
 		doneCh: make(chan struct{}),
@@ -46,11 +46,6 @@ func (e *Engine) Execute(stateCtx *StateCtx) error {
 		defer e.wg.Done()
 	}
 
-	if stateCtx.ExecID == 0 {
-		stateCtx.ExecID = execIDS.Add(1)
-	}
-	execID := stateCtx.ExecID
-
 	stateCtx.e = e
 
 	if stateCtx.Current.ID == `` {
@@ -73,7 +68,7 @@ func (e *Engine) Execute(stateCtx *StateCtx) error {
 			return err
 		}
 
-		slog.Info("executing", "exec_id", execID, "state_id", stateCtx.Current.ID, "state_rev", stateCtx.Current.Rev, "flow", stateCtx.Current.Transition.ToID)
+		e.l.Info("flowstate: executing", logWithStateCtx(stateCtx, []any{"flow", stateCtx.Current.Transition.ToID}))
 		cmd0, err := f.Execute(stateCtx, e)
 		if err != nil {
 			return err
diff --git a/go.mod b/go.mod
index de7a680..afa7ceb 100644
--- a/go.mod
+++ b/go.mod
@@ -7,6 +7,7 @@ require (
 	github.com/jackc/pgx/v5 v5.6.0
 	github.com/mattn/go-sqlite3 v1.14.22
 	github.com/stretchr/testify v1.9.0
+	github.com/thejerf/slogassert v0.3.4
 	github.com/xo/dburl v0.23.2
 	go.uber.org/goleak v1.3.0
 	golang.org/x/time v0.5.0
diff --git a/go.sum b/go.sum
index 2e19f69..f98afe3 100644
--- a/go.sum
+++ b/go.sum
@@ -27,6 +27,8 @@ github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UV
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
 github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
+github.com/thejerf/slogassert v0.3.4 h1:VoTsXixRbXMrRSSxDjYTiEDCM4VWbsYPW5rB/hX24kM=
+github.com/thejerf/slogassert v0.3.4/go.mod h1:0zn9ISLVKo1aPMTqcGfG1o6dWwt+Rk574GlUxHD4rs8=
 github.com/xo/dburl v0.23.2 h1:Fl88cvayrgE56JA/sqhNMLljCW/b7RmG1mMkKMZUFgA=
 github.com/xo/dburl v0.23.2/go.mod h1:uazlaAQxj4gkshhfuuYyvwCBouOmNnG2aDxTCFZpmL4=
 go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
diff --git a/state.go b/state.go
index 91bea81..ccbf5e1 100644
--- a/state.go
+++ b/state.go
@@ -75,8 +75,7 @@ type StateCtx struct {
 	// Transitions between committed and current states
 	Transitions []Transition `json:"transitions"`
 
-	ExecID int64   `json:"-"`
-	e      *Engine `json:"-"`
+	e *Engine `json:"-"`
 }
 
 func (s *StateCtx) CopyTo(to *StateCtx) *StateCtx {
diff --git a/testcases/actor.go b/testcases/actor.go
index 206ebfb..74706a6 100644
--- a/testcases/actor.go
+++ b/testcases/actor.go
@@ -49,7 +49,8 @@ func Actor(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return nil, fmt.Errorf("must never be executed")
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/call_flow.go b/testcases/call_flow.go
index d8f7907..32a2c41 100644
--- a/testcases/call_flow.go
+++ b/testcases/call_flow.go
@@ -79,7 +79,8 @@ func CallFlow(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/call_flow_with_commit.go b/testcases/call_flow_with_commit.go
index 323a690..72fd18e 100644
--- a/testcases/call_flow_with_commit.go
+++ b/testcases/call_flow_with_commit.go
@@ -89,7 +89,8 @@ func CallFlowWithCommit(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/call_flow_with_watch.go b/testcases/call_flow_with_watch.go
index 79912c0..b83c7de 100644
--- a/testcases/call_flow_with_watch.go
+++ b/testcases/call_flow_with_watch.go
@@ -97,7 +97,8 @@ func CallFlowWithWatch(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/condition.go b/testcases/condition.go
index f881cc0..0e70783 100644
--- a/testcases/condition.go
+++ b/testcases/condition.go
@@ -33,7 +33,8 @@ func Condition(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/cron.go b/testcases/cron.go
index cb4f76b..bd70519 100644
--- a/testcases/cron.go
+++ b/testcases/cron.go
@@ -87,7 +87,8 @@ func Cron(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/data_flow_config.go b/testcases/data_flow_config.go
index fb11c9b..76602f1 100644
--- a/testcases/data_flow_config.go
+++ b/testcases/data_flow_config.go
@@ -125,7 +125,8 @@ func DataFlowConfig(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/data_store_get.go b/testcases/data_store_get.go
index 7d5a448..fea99d4 100644
--- a/testcases/data_store_get.go
+++ b/testcases/data_store_get.go
@@ -63,7 +63,8 @@ func DataStoreGet(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/data_store_get_with_commit.go b/testcases/data_store_get_with_commit.go
index b775b02..3d09095 100644
--- a/testcases/data_store_get_with_commit.go
+++ b/testcases/data_store_get_with_commit.go
@@ -63,7 +63,8 @@ func DataStoreGetWithCommit(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/delay_delayed_win_with_commit.go b/testcases/delay_delayed_win_with_commit.go
index 4ce3df8..fd7739c 100644
--- a/testcases/delay_delayed_win_with_commit.go
+++ b/testcases/delay_delayed_win_with_commit.go
@@ -48,7 +48,8 @@ func Delay_DelayedWin_WithCommit(t TestingT, d flowstate.Doer, fr FlowRegistry)
 		), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/delay_engine_do.go b/testcases/delay_engine_do.go
index 3d075fb..41829c9 100644
--- a/testcases/delay_engine_do.go
+++ b/testcases/delay_engine_do.go
@@ -33,7 +33,8 @@ func Delay_EngineDo(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/delay_paused.go b/testcases/delay_paused.go
index ed8eb7a..3288ea5 100644
--- a/testcases/delay_paused.go
+++ b/testcases/delay_paused.go
@@ -38,7 +38,8 @@ func Delay_Paused(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/delay_paused_with_commit.go b/testcases/delay_paused_with_commit.go
index 175e22d..7424edf 100644
--- a/testcases/delay_paused_with_commit.go
+++ b/testcases/delay_paused_with_commit.go
@@ -40,7 +40,8 @@ func Delay_PausedWithCommit(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/delay_return.go b/testcases/delay_return.go
index 9245f68..f077ec6 100644
--- a/testcases/delay_return.go
+++ b/testcases/delay_return.go
@@ -27,7 +27,8 @@ func Delay_Return(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/delay_transited_win_with_commit.go b/testcases/delay_transited_win_with_commit.go
index 81f2731..2baddb5 100644
--- a/testcases/delay_transited_win_with_commit.go
+++ b/testcases/delay_transited_win_with_commit.go
@@ -44,7 +44,8 @@ func Delay_TransitedWin_WithCommit(t TestingT, d flowstate.Doer, fr FlowRegistry
 		), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/fork.go b/testcases/fork.go
index 57f0702..410f429 100644
--- a/testcases/fork.go
+++ b/testcases/fork.go
@@ -51,7 +51,8 @@ func Fork(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/fork_join_first_wins.go b/testcases/fork_join_first_wins.go
index fe8d469..24248c0 100644
--- a/testcases/fork_join_first_wins.go
+++ b/testcases/fork_join_first_wins.go
@@ -104,7 +104,8 @@ func ForkJoin_FirstWins(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/fork_join_last_wins.go b/testcases/fork_join_last_wins.go
index 6db87b1..7258a66 100644
--- a/testcases/fork_join_last_wins.go
+++ b/testcases/fork_join_last_wins.go
@@ -105,7 +105,8 @@ func ForkJoin_LastWins(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/fork_with_commit.go b/testcases/fork_with_commit.go
index 648f39d..59a165e 100644
--- a/testcases/fork_with_commit.go
+++ b/testcases/fork_with_commit.go
@@ -53,7 +53,8 @@ func Fork_WithCommit(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/get_by_id_and_rev.go b/testcases/get_by_id_and_rev.go
index bc1f8d3..ceb6389 100644
--- a/testcases/get_by_id_and_rev.go
+++ b/testcases/get_by_id_and_rev.go
@@ -12,7 +12,8 @@ import (
 func GetByIDAndRev(t TestingT, d flowstate.Doer, _ FlowRegistry) {
 	defer goleak.VerifyNone(t, goleak.IgnoreCurrent())
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/get_latest_by_id.go b/testcases/get_latest_by_id.go
index 24c02db..23e5be6 100644
--- a/testcases/get_latest_by_id.go
+++ b/testcases/get_latest_by_id.go
@@ -12,7 +12,8 @@ import (
 func GetLatestByID(t TestingT, d flowstate.Doer, _ FlowRegistry) {
 	defer goleak.VerifyNone(t, goleak.IgnoreCurrent())
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/get_latest_by_label.go b/testcases/get_latest_by_label.go
index eed7937..f04dc9c 100644
--- a/testcases/get_latest_by_label.go
+++ b/testcases/get_latest_by_label.go
@@ -12,7 +12,8 @@ import (
 func GetLatestByLabel(t TestingT, d flowstate.Doer, _ FlowRegistry) {
 	defer goleak.VerifyNone(t, goleak.IgnoreCurrent())
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/get_not_found.go b/testcases/get_not_found.go
index 615a0a6..858237b 100644
--- a/testcases/get_not_found.go
+++ b/testcases/get_not_found.go
@@ -12,7 +12,8 @@ import (
 func GetNotFound(t TestingT, d flowstate.Doer, _ FlowRegistry) {
 	defer goleak.VerifyNone(t, goleak.IgnoreCurrent())
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/log.go b/testcases/log.go
new file mode 100644
index 0000000..c98a312
--- /dev/null
+++ b/testcases/log.go
@@ -0,0 +1,14 @@
+package testcases
+
+import (
+	"log/slog"
+
+	"github.com/thejerf/slogassert"
+)
+
+func newTestLogger(t TestingT) (*slog.Logger, *slogassert.Handler) {
+	h := slogassert.New(t, slog.LevelWarn, nil)
+	l := slog.New(h)
+
+	return l, h
+}
diff --git a/testcases/mutex.go b/testcases/mutex.go
index 743aa5f..b398bc1 100644
--- a/testcases/mutex.go
+++ b/testcases/mutex.go
@@ -118,7 +118,8 @@ func Mutex(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		states = append(states, statesCtx)
 	}
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/queue.go b/testcases/queue.go
index 8436f9f..5e59ec1 100644
--- a/testcases/queue.go
+++ b/testcases/queue.go
@@ -69,7 +69,8 @@ func Queue(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/rate_limit.go b/testcases/rate_limit.go
index 0c9d2bc..853bb34 100644
--- a/testcases/rate_limit.go
+++ b/testcases/rate_limit.go
@@ -92,7 +92,8 @@ func RateLimit(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		states = append(states, stateCtx)
 	}
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/recovery_always_fail.go b/testcases/recovery_always_fail.go
index ac53bb9..69134e0 100644
--- a/testcases/recovery_always_fail.go
+++ b/testcases/recovery_always_fail.go
@@ -20,7 +20,8 @@ func RecoveryAlwaysFail(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.Noop(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/recovery_first_attempt_fail.go b/testcases/recovery_first_attempt_fail.go
index a4754f3..a1fbf10 100644
--- a/testcases/recovery_first_attempt_fail.go
+++ b/testcases/recovery_first_attempt_fail.go
@@ -27,7 +27,8 @@ func RecoveryFirstAttemptFail(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/single_node.go b/testcases/single_node.go
index 61ddfcb..76c69ac 100644
--- a/testcases/single_node.go
+++ b/testcases/single_node.go
@@ -19,7 +19,8 @@ func SingleNode(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/suite.go b/testcases/suite.go
index b08adb5..d4974fd 100644
--- a/testcases/suite.go
+++ b/testcases/suite.go
@@ -7,6 +7,7 @@ import (
 )
 
 type TestingT interface {
+	Helper()
 	Error(...interface{})
 	Errorf(format string, args ...interface{})
 	Fatalf(format string, args ...any)
diff --git a/testcases/three_consequent_nodes.go b/testcases/three_consequent_nodes.go
index 449d38e..c32eda3 100644
--- a/testcases/three_consequent_nodes.go
+++ b/testcases/three_consequent_nodes.go
@@ -27,7 +27,8 @@ func ThreeConsequentNodes(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/two_consequent_nodes.go b/testcases/two_consequent_nodes.go
index 76e9f57..10c15ae 100644
--- a/testcases/two_consequent_nodes.go
+++ b/testcases/two_consequent_nodes.go
@@ -23,7 +23,8 @@ func TwoConsequentNodes(t TestingT, d flowstate.Doer, fr FlowRegistry) {
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/two_consequent_nodes_with_commit.go b/testcases/two_consequent_nodes_with_commit.go
index 4123e51..87c68c2 100644
--- a/testcases/two_consequent_nodes_with_commit.go
+++ b/testcases/two_consequent_nodes_with_commit.go
@@ -29,7 +29,8 @@ func TwoConsequentNodesWithCommit(t TestingT, d flowstate.Doer, fr FlowRegistry)
 		return flowstate.End(stateCtx), nil
 	}))
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	require.NoError(t, err)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
diff --git a/testcases/watch_labels.go b/testcases/watch_labels.go
index 2b18283..71c7565 100644
--- a/testcases/watch_labels.go
+++ b/testcases/watch_labels.go
@@ -13,7 +13,8 @@ import (
 func WatchLabels(t TestingT, d flowstate.Doer, _ FlowRegistry) {
 	defer goleak.VerifyNone(t, goleak.IgnoreCurrent())
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
 		defer sCtxCancel()
diff --git a/testcases/watch_or_labels.go b/testcases/watch_or_labels.go
index 9dd51d0..07e844c 100644
--- a/testcases/watch_or_labels.go
+++ b/testcases/watch_or_labels.go
@@ -12,7 +12,8 @@ import (
 func WatchORLabels(t TestingT, d flowstate.Doer, _ FlowRegistry) {
 	defer goleak.VerifyNone(t, goleak.IgnoreCurrent())
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
 		defer sCtxCancel()
diff --git a/testcases/watch_since_latest.go b/testcases/watch_since_latest.go
index e65b0ff..65105aa 100644
--- a/testcases/watch_since_latest.go
+++ b/testcases/watch_since_latest.go
@@ -12,7 +12,8 @@ import (
 func WatchSinceLatest(t TestingT, d flowstate.Doer, _ FlowRegistry) {
 	defer goleak.VerifyNone(t, goleak.IgnoreCurrent())
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
 		defer sCtxCancel()
diff --git a/testcases/watch_since_rev.go b/testcases/watch_since_rev.go
index f22ae0e..997864f 100644
--- a/testcases/watch_since_rev.go
+++ b/testcases/watch_since_rev.go
@@ -12,7 +12,8 @@ import (
 func WatchSinceRev(t TestingT, d flowstate.Doer, _ FlowRegistry) {
 	defer goleak.VerifyNone(t, goleak.IgnoreCurrent())
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
 		defer sCtxCancel()
diff --git a/testcases/watch_since_time.go b/testcases/watch_since_time.go
index 9c1466e..d454fef 100644
--- a/testcases/watch_since_time.go
+++ b/testcases/watch_since_time.go
@@ -12,7 +12,8 @@ import (
 func WatchSinceTime(t TestingT, d flowstate.Doer, _ FlowRegistry) {
 	defer goleak.VerifyNone(t, goleak.IgnoreCurrent())
 
-	e, err := flowstate.NewEngine(d)
+	l, _ := newTestLogger(t)
+	e, err := flowstate.NewEngine(d, l)
 	defer func() {
 		sCtx, sCtxCancel := context.WithTimeout(context.Background(), time.Second*5)
 		defer sCtxCancel()