Add fsnotify create (#1204)

ansible · Oct 31, 2024 · 5538db6 · 5538db6
1 parent 9acd1c0
commit 5538db6
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/workceptor/workunitbase.go b/pkg/workceptor/workunitbase.go
@@ -432,7 +432,9 @@ loop:
 		case <-bwu.ctx.Done():
 			break loop
 		case event := <-watcherEvents:
-			if event.Op&fsnotify.Write == fsnotify.Write {
+			if event.Has(fsnotify.Create) {
+				bwu.w.nc.GetLogger().Debug("Watcher Event create of %s", statusFile)
+			} else if event.Op&fsnotify.Write == fsnotify.Write {
 				err = bwu.Load()
 				if err != nil {
 					bwu.w.nc.GetLogger().Error("Watcher Events Error reading %s: %s", statusFile, err)