diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
index 1763db20a8..b89249031f 100644
--- 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 {