always ingest the most recent raw for a suid

CenterForOpenScience · Feb 10, 2021 · 55b50b5 · 55b50b5
1 parent 04ad89b
commit 55b50b5
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/share/tasks/jobs.py b/share/tasks/jobs.py
@@ -298,13 +298,13 @@ def _consume_job(self, job, superfluous, force, apply_changes=True, index=True,
         datum = None
         graph = None
 
+        most_recent_raw = job.suid.most_recent_raw_datum()
+
         # Check whether we've already done transform/regulate
         if not superfluous:
-            datum = job.ingested_normalized_data.order_by('-created_at').first()
+            datum = job.ingested_normalized_data.filter(raw=most_recent_raw).order_by('-created_at').first()
 
         if superfluous or datum is None:
-            most_recent_raw = job.suid.most_recent_raw_datum()
-
             graph = self._transform(job, most_recent_raw)
             if not graph:
                 return