diff --git a/trace/subscription.go b/trace/subscription.go
index de767c82..f77977e4 100644
--- a/trace/subscription.go
+++ b/trace/subscription.go
@@ -37,7 +37,7 @@ func (m *manager) broadcast(update *types.TraceUpdate) {
 					// Channel was closed, ignore (subscriber cleanup race condition)
 				}
 			}()
-			
+
 			select {
 			case ch <- update:
 				// Sent successfully
diff --git a/trace/trace_bench_test.go b/trace/trace_bench_test.go
index 91d36dd6..46afc44d 100644
--- a/trace/trace_bench_test.go
+++ b/trace/trace_bench_test.go
@@ -491,4 +491,3 @@ func getTraceScenarios() []traceScenario {
 		},
 	}
 }
-
diff --git a/trace/trace_concurrent_test.go b/trace/trace_concurrent_test.go
index f4f2f44e..c98797ff 100644
--- a/trace/trace_concurrent_test.go
+++ b/trace/trace_concurrent_test.go
@@ -80,7 +80,7 @@ func TestConcurrentSpaceOperations(t *testing.T) {
 			// Concurrent writes to the SAME space (now thread-safe with per-space locks)
 			var wg sync.WaitGroup
 			numWorkers := 10
-			
+
 			for i := 0; i < numWorkers; i++ {
 				wg.Add(1)
 				go func(idx int) {
@@ -282,4 +282,3 @@ func TestConcurrentLogging(t *testing.T) {
 		})
 	}
 }
-
diff --git a/trace/trace_mem_test.go b/trace/trace_mem_test.go
index 3aef6ae9..6b62be78 100644
--- a/trace/trace_mem_test.go
+++ b/trace/trace_mem_test.go
@@ -618,4 +618,3 @@ func TestGoroutineLeak(t *testing.T) {
 		t.Logf("✓ No goroutine leak detected")
 	}
 }
-
diff --git a/trace/trace_node_test.go b/trace/trace_node_test.go
index 58d45d49..27d7de2e 100644
--- a/trace/trace_node_test.go
+++ b/trace/trace_node_test.go
@@ -211,4 +211,3 @@ func TestCompleteWithOutput(t *testing.T) {
 		})
 	}
 }
-
diff --git a/trace/trace_space_test.go b/trace/trace_space_test.go
index 3caa3aec..b1e6c53f 100644
--- a/trace/trace_space_test.go
+++ b/trace/trace_space_test.go
@@ -176,11 +176,10 @@ func TestSpaceGetSpace(t *testing.T) {
 			assert.Equal(t, "Test description", retrieved.Description)
 			assert.Equal(t, int64(7200), retrieved.TTL)
 
-		// Get non-existent space (returns nil, nil)
-		nonExistent, err := manager.GetSpace("nonexistent")
-		assert.NoError(t, err)
-		assert.Nil(t, nonExistent)
+			// Get non-existent space (returns nil, nil)
+			nonExistent, err := manager.GetSpace("nonexistent")
+			assert.NoError(t, err)
+			assert.Nil(t, nonExistent)
 		})
 	}
 }
-
diff --git a/trace/trace_subscription_test.go b/trace/trace_subscription_test.go
index 77ddf086..a7a9c863 100644
--- a/trace/trace_subscription_test.go
+++ b/trace/trace_subscription_test.go
@@ -153,15 +153,15 @@ func TestSubscribeFrom(t *testing.T) {
 						// Channel closed
 						break collectLoop
 					}
-				receivedUpdates = append(receivedUpdates, update)
-				// Check if we received step 2 events
-				if update.Type == types.UpdateTypeNodeStart {
-					if data, ok := update.Data.(*types.NodeStartData); ok {
-						if data.Node != nil && data.Node.Label == "Finalizing" {
-							foundStep2 = true
+					receivedUpdates = append(receivedUpdates, update)
+					// Check if we received step 2 events
+					if update.Type == types.UpdateTypeNodeStart {
+						if data, ok := update.Data.(*types.NodeStartData); ok {
+							if data.Node != nil && data.Node.Label == "Finalizing" {
+								foundStep2 = true
+							}
 						}
 					}
-				}
 					// Stop after receiving trace_complete
 					if update.Type == types.UpdateTypeComplete {
 						break collectLoop
@@ -280,4 +280,3 @@ func TestMultipleSubscribers(t *testing.T) {
 		})
 	}
 }
-