Update scheduler.go to close file descriptor after encoding items

WangYihang · Aug 29, 2024 · 0409504 · 0409504
1 parent e7537f8
commit 0409504
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/scheduler.go b/scheduler.go
@@ -232,13 +232,13 @@ func chanRecorder[T *basicTask | Status | schedulerMetadata](path string, ch <-c
 		return
 	}
 	go func() {
-		defer fd.Close()
 		encoder := json.NewEncoder(fd)
 		for item := range ch {
 			if err := encoder.Encode(item); err != nil {
 				slog.Error("error occurred while serializing data", slog.String("path", path), slog.String("error", err.Error()))
 			}
 		}
+		fd.Close()
 		wg.Done()
 	}()
 }