Index: trunk/ippToPsps/jython/ipptopspsdb.py
===================================================================
--- trunk/ippToPsps/jython/ipptopspsdb.py	(revision 32141)
+++ trunk/ippToPsps/jython/ipptopspsdb.py	(revision 32162)
@@ -294,9 +294,10 @@
     Have we already processed and published this batch?
     '''
-    def alreadyProcessed(self, stage_id):
+    def alreadyProcessed(self, batchType, stage_id):
 
         sql = "SELECT COUNT(*) \
                FROM batch \
                WHERE stage_id = " + str(stage_id) + " \
+               AND batch_type = '" + batchType + "' \
                AND processed \
                AND loaded_to_datastore"