Skip to content

Commit 86c183a

Browse files
committed
fix: don't process temporary files
1 parent 7f89650 commit 86c183a

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

server/scheduler.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,11 @@ func (s *Server) schedulerIngestJobs(_ time.Time) {
3434
if d.IsDir() {
3535
return nil
3636
}
37+
if filepath.Ext(path) != ".json" {
38+
// renameio firstly creates files like `.{fname}NNNNNNNNNNNNNNNNNNN`
39+
// that we should ignore
40+
return nil
41+
}
3742
j, err := job.Load(path)
3843
if err != nil {
3944
j = job.NewCleanupUnparseableJob(path, err)

0 commit comments

Comments
 (0)