minor change

PeerDB-io · Feb 19, 2024 · 8a87191 · 8a87191
1 parent c3bf4e5
commit 8a87191
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -204,7 +204,7 @@ func (a *FlowableActivity) StartFlow(ctx context.Context,
 	})
 	defer shutdown()
 
-	slog.Info("getting last offset from destination peer")
+	slog.InfoContext(ctx, "getting last offset from destination peer")
 	// Get the last offset from the destination
 	lastOffset, getLastOffsetErr := dstConn.GetLastOffset(input.FlowConnectionConfigs.FlowJobName)
 	if getLastOffsetErr != nil {