fix(warehouse): all staging files processing failed (#3137)

rudderlabs · Mar 30, 2023 · 9dc4b8f · 9dc4b8f
1 parent cdff792
commit 9dc4b8f
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/warehouse/internal/loadfiles/loadfiles.go b/warehouse/internal/loadfiles/loadfiles.go
@@ -285,6 +285,10 @@ func (lf *LoadFileGenerator) createFromStaging(ctx context.Context, job *model.U
 				successfulStagingFileIDs = append(successfulStagingFileIDs, resp.JobID)
 			}
 
+			if len(loadFiles) == 0 {
+				return nil
+			}
+
 			err = lf.LoadRepo.Insert(ctx, loadFiles)
 			if err != nil {
 				return fmt.Errorf("inserting load files: %w", err)