feat: Add a lock to filechangecapture in test

influxdata · Jan 7, 2025 · 8996d14 · 8996d14
1 parent 5b7896a
commit 8996d14
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/query/executor_test.go b/query/executor_test.go
@@ -708,6 +708,8 @@ func (m *mockWatcher) GetLogPath() string {
 }
 
 func (m *mockWatcher) FileChangeCapture() error {
+	m.Mu.Lock()
+	defer m.Mu.Unlock()
 	err := m.Remove(m.path)
 	if err != nil {
 		return err