diff --git a/persistence.go b/persistence.go
index 1f2b283b0981dc74c51d18ab79e40129c4aaff7f..8188a741ed068e8f85ba366a6c705fa877cac12f 100644
--- a/persistence.go
+++ b/persistence.go
@@ -104,7 +104,7 @@ func ReadFromGORM(db *gorm.DB) ([]JobPersistence, error) {
 		var wrappedErr []error
 		// load stats too
 		for i := range jobs {
-			if err := db.Model(&jobs[i]).Association("Stats").Find(&jobs[i].Stats); err != nil {
+			if err := tx.Model(&jobs[i]).Association("Stats").Find(&jobs[i].Stats); err != nil {
 				wrappedErr = append(wrappedErr, err)
 			}
 		}