filed

Job queue using FUSE

git clone git://mccd.space/filed

commit cffea16ebe86cb3afe88683eb843fdb6363c6918
parent 3762623c577c98849326b9086c7325aed71135c6
Author: Marc Coquand <marc@coquand.email>
Date:   Mon, 15 Dec 2025 21:31:00 +0100

Logging

Diffstat:
M
manager.go
 | 
2
+-
M
pendingdir.go
 | 
4
++--

2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/manager.go b/manager.go
@@ -80,7 +80,7 @@ func (jm *JobManager) processPendingJobs() {
 			continue
 		}
 		if jm.isReady(&conf, &job) {
-			slog.Info("Worker: Starting job", "id", job.ID, "cmd", job.Command, "attempt", job.Attempts)
+			slog.Info("Worker: Starting job", "id", job.ID, "cmd", job.Command, "attempt", job.Attempts+1)
 			if err := jm.store.AttemptJob(job.ID); err != nil {
 				slog.Error("Worker: Failed to claim job", "id", job.ID, "error", err)
 				continue
diff --git a/pendingdir.go b/pendingdir.go
@@ -129,10 +129,10 @@ func (f *File) readContent() ([]byte, error) {
 	liveLog := f.manager.GetLiveLog(f.job.ID)
 
 	if liveLog != nil {
-		slog.Info("Using live output")
+		slog.Debug("FUSE: Using live output")
 		output = liveLog
 	} else {
-		slog.Info("Using job output")
+		slog.Debug("FUSE: Using job output")
 		output = f.job.Output
 	}