Index: trunk/ippToPsps/jython/ipptopspsdb.py
===================================================================
--- trunk/ippToPsps/jython/ipptopspsdb.py	(revision 31860)
+++ trunk/ippToPsps/jython/ipptopspsdb.py	(revision 31861)
@@ -59,32 +59,11 @@
     TODO
     '''
-    def getUnprocessedIDsForThisStage(self, dvoDb, batchType, startDate):
-
-        if batchType == "P2": # TODO define these someplace 
-
-            stage = "cam"
-            sql = "SELECT DISTINCT stage_id \
-                   FROM gpc1.addRun \
-                   WHERE stage = '" + stage + "' \
-                   AND dvodb = '" + dvoDb + "' \
-                   AND state = 'full' \
-                   AND stage_id NOT IN "
-
-        elif batchType == "ST": 
-
-            stage = "staticsky"
-            sql = "SELECT DISTINCT stack_id \
-                   FROM gpc1.staticskyInput \
-                   JOIN gpc1.addRun ON(gpc1.staticskyInput.sky_id = gpc1.addRun.stage_id) \
-                   WHERE stage = '" + stage + "' \
-                   AND dvodb = '" + dvoDb + "' \
-                   AND state = 'full' \
-                   AND stack_id NOT IN "
-
-        sql = sql + "(SELECT stage_id \
-              FROM batch \
-              WHERE batch_type = '" + batchType + "' \
-              AND timestamp > '" + startDate + "' \
-              AND loaded_to_datastore)"
+    def getProcessedIDsForThisStage(self, batchType, startDate):
+
+        sql = "SELECT stage_id \
+               FROM batch \
+               WHERE batch_type = '" + batchType + "' \
+               AND timestamp > '" + startDate + "' \
+               AND loaded_to_datastore"
 
         ids = []
@@ -94,9 +73,9 @@
                 ids.append(rs.getInt(1))
         except:
-            self.logger.exception("Can't query for ids in DVO")
+            self.logger.exception("Can't query for processed ids in ipptopsps Db")
 
         rs.close()
 
-        self.logger.debug("Found %d unprocessed items in DVO database '%s' for stage='%s'" % (len(ids), dvoDb, stage))
+        self.logger.debug("Found %d processed and published items for batchType='%s'" % (len(ids), batchType))
 
         return ids