Index: trunk/ippToPsps/jython/Makefile.am
===================================================================
--- trunk/ippToPsps/jython/Makefile.am	(revision 38965)
+++ trunk/ippToPsps/jython/Makefile.am	(revision 38969)
@@ -23,4 +23,5 @@
   forcedobjectbatch.py \
   forcedwarpbatch.py \
+  forcedgalaxybatch.py \
   gpc1db.py \
   initbatch.py \
Index: trunk/ippToPsps/jython/ipptopspsdb.py
===================================================================
--- trunk/ippToPsps/jython/ipptopspsdb.py	(revision 38965)
+++ trunk/ippToPsps/jython/ipptopspsdb.py	(revision 38969)
@@ -1104,4 +1104,5 @@
         ,queue_FW \
         ,queue_FO \
+        ,queue_FG \
         ,parallel \
         ,P2_smf_version \
@@ -1180,4 +1181,5 @@
         if rs.getInt(24) == 1: self.skychunk.batchTypes.append("FW")
         if rs.getInt(25) == 1: self.skychunk.batchTypes.append("FO")
+        if rs.getInt(25) == 1: self.skychunk.batchTypes.append("FG")
 
         self.skychunk.force = True # TODO
Index: trunk/ippToPsps/jython/loader.py
===================================================================
--- trunk/ippToPsps/jython/loader.py	(revision 38965)
+++ trunk/ippToPsps/jython/loader.py	(revision 38969)
@@ -29,4 +29,5 @@
 from forcedwarpbatch import ForcedWarpBatch 
 from forcedobjectbatch import ForcedObjectBatch
+from forcedgalaxybatch import ForcedGalaxyBatch
 #
 #
@@ -291,4 +292,14 @@
                             id,
                             batchID)
+
+                elif batchType == "FG":
+                    batch = ForcedGalaxyBatch(self.logger,
+                                              self.config,
+                                              self.skychunk,
+                                              self.gpc1Db,
+                                              self.ippToPspsDb,
+                                              self.scratchDb,
+                                              id,
+                                              batchID)
                     
                 batch.run()
Index: trunk/ippToPsps/jython/metrics.py
===================================================================
--- trunk/ippToPsps/jython/metrics.py	(revision 38965)
+++ trunk/ippToPsps/jython/metrics.py	(revision 38969)
@@ -52,4 +52,5 @@
             rateFW = self.printStats("FW")
             rateFO = self.printStats("FO")
+            rateFG = self.printStats("FG")
             self.logger.info("+----+------------------+---------------+-------------------+------------------+----------------+")
         
@@ -74,4 +75,5 @@
             pendFWProcessed = self.printTableRow(stages, "FW")
             pendFOProcessed = self.printTableRow(stages, "FO")
+            pendFGProcessed = self.printTableRow(stages, "FG")
             self.writeTableSeparator(colCount)
 
@@ -90,4 +92,6 @@
             except: pass
             try: self.logger.infoPair("Estimated time for FOs", "%.1f hours" % (pendFOProcessed / rateFO)) 
+            except: pass
+            try: self.logger.infoPair("Estimated time for FGs", "%.1f hours" % (pendFGProcessed / rateFG)) 
             except: pass
        
@@ -102,4 +106,5 @@
             self.plot.createDensityPlot("FW", True)
             self.plot.createDensityPlot("FO", True)
+            self.plot.createDensityPlot("FG", True)
             # some clean-up before going to sleep
             self.ippToPspsDb.purgeDeadClients()
Index: trunk/ippToPsps/jython/pollOdm.py
===================================================================
--- trunk/ippToPsps/jython/pollOdm.py	(revision 38965)
+++ trunk/ippToPsps/jython/pollOdm.py	(revision 38969)
@@ -42,5 +42,5 @@
         else: self.stages = [self.STAGE]
 
-        if self.BATCHTYPE == "all": self.batchTypes = ['IN', 'P2', 'ST', 'OB', 'DF', 'DO', 'FW', 'FO']
+        if self.BATCHTYPE == "all": self.batchTypes = ['IN', 'P2', 'ST', 'OB', 'DF', 'DO', 'FW', 'FO', 'FG']
         else: self.batchTypes = [self.BATCHTYPE]
 
@@ -126,5 +126,5 @@
     '''
     def printUsage(self):
-        super(PollOdm, self).printUsage("<IN|P2|ST|OB|DF|DO|FW|FO|all> <unloaded|unmergeworthy|unmerged|all> [hours]")
+        super(PollOdm, self).printUsage("<IN|P2|ST|OB|DF|DO|FW|FO|FG|all> <unloaded|unmergeworthy|unmerged|all> [hours]")
     
     
Index: trunk/ippToPsps/jython/queue.py
===================================================================
--- trunk/ippToPsps/jython/queue.py	(revision 38965)
+++ trunk/ippToPsps/jython/queue.py	(revision 38969)
@@ -73,5 +73,5 @@
 
                 # for object-like batches, info comes from dvo
-                if (batchType == "OB" or batchType =="DO" or batchType =="FO"):
+                if (batchType == "OB" or batchType =="DO" or batchType =="FO" or batchType = "FG"):
                     self.dvoObjects.setSkyArea(
                             self.skychunk.minRa,