Fix

maxpert · Dec 28, 2023 · e2528ad · e2528ad
1 parent cdfa495
commit e2528ad
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/db/change_log.go b/db/change_log.go
@@ -263,6 +263,7 @@ func (conn *SqliteStreamDB) filterChangesTo(changed chan fsnotify.Event, watcher
 			}
 
 			if ev.Op == fsnotify.Chmod {
+				time.Sleep(1 * time.Millisecond)
 				continue
 			}
 
@@ -285,7 +286,7 @@ func (conn *SqliteStreamDB) watchChanges(watcher *fsnotify.Watcher, path string)
 
 	// Publish change logs for any residual change logs before starting watcher
 	conn.publishChangeLog()
-	conn.filterChangesTo(dbChanged, watcher)
+	go conn.filterChangesTo(dbChanged, watcher)
 
 	for {
 		changeLogTicker.Reset()