Index: /trunk/ippToPsps/config/ippToPspsDbSchema.sql
===================================================================
--- /trunk/ippToPsps/config/ippToPspsDbSchema.sql (revision 37926)
+++ /trunk/ippToPsps/config/ippToPspsDbSchema.sql (revision 37927)
@@ -199,5 +199,5 @@
`region` varchar(50) default NULL,
KEY `batch_id` (`batch_id`),
- CONSTRAINT `diffobject_fk_1` FOREIGN KEY (`batch_id`) REFERENCES `batch` (`batch_id`)
+ CONSTRAINT `forcedobject_fk_1` FOREIGN KEY (`batch_id`) REFERENCES `batch` (`batch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1;
SET character_set_client = @saved_cs_client;
Index: /trunk/ippToPsps/config/tables.FO.vot
===================================================================
--- /trunk/ippToPsps/config/tables.FO.vot (revision 37926)
+++ /trunk/ippToPsps/config/tables.FO.vot (revision 37927)
@@ -264,19 +264,4 @@
flags for i forced
-
- per-object smear polarizability X11 term
-
-
- per-object smear polarizability X12 term
-
-
- per-object smear polarizability X22 term
-
-
- per-object smear polarizability E1 term
-
-
- per-object smear polarizability E2 term
-
second moment (Mxx+Myy)
@@ -460,6 +445,6 @@
-
- VOTable description of PSPS table ForcedMeanObject
+
+ VOTable description of PSPS table ForcedMeanLensing
@@ -607,4 +592,19 @@
stack image id (how to carry through IPP+DVO
+
+ per-object smear polarizability X11 term
+
+
+ per-object smear polarizability X12 term
+
+
+ per-object smear polarizability X22 term
+
+
+ per-object smear polarizability E1 term
+
+
+ per-object smear polarizability E2 term
+
per-object shear polarizability X11 term
@@ -778,4 +778,7 @@
psf model shear polarizability E2 term
+
+
+
Index: /trunk/ippToPsps/jython/Makefile.am
===================================================================
--- /trunk/ippToPsps/jython/Makefile.am (revision 37926)
+++ /trunk/ippToPsps/jython/Makefile.am (revision 37927)
@@ -14,4 +14,5 @@
diffobjectbatch.py \
dvodetections.py \
+ dvodiffobjects.py \
dvoforceddetections.py \
dvoforcedobjects.py \
Index: /trunk/ippToPsps/jython/diffobjectbatch.py
===================================================================
--- /trunk/ippToPsps/jython/diffobjectbatch.py (revision 37926)
+++ /trunk/ippToPsps/jython/diffobjectbatch.py (revision 37927)
@@ -14,5 +14,6 @@
from ipptopspsdb import IppToPspsDb
from scratchdb import ScratchDb
-from dvoobjects import DvoObjects
+#from dvoobjects import DvoObjects
+from dvodiffobjects import DvoDiffObjects
from sqlUtility import sqlUtility
@@ -53,7 +54,7 @@
try:
- self.dvoObjects = DvoObjects(self.logger, self.config, self.skychunk, self.ippToPspsDb, self.scratchDb)
+ self.dvoDiffObjects = DvoDiffObjects(self.logger, self.config, self.skychunk, self.ippToPspsDb, self.scratchDb)
except:
- self.logger.errorPair("Unable to create instance of", "DvoObjects")
+ self.logger.errorPair("Unable to create instance of", "DvoDiffObjects")
raise
@@ -72,5 +73,5 @@
self.region = self.scratchDb.getRegionNameFromThisDvoIndex(self.id)
self.ippToPspsDb.insertObjectMeta(self.batchID, self.region)
- self.dvoObjects.nativeIngestRegion(self.region)
+ self.dvoDiffObjects.nativeIngestRegion(self.region)
cptTableName = self.scratchDb.getDbFriendlyTableName(self.region + ".cpt")
@@ -184,19 +185,21 @@
except:
self.logger.errorPair("failed sql", sql)
+ raise
return False
# XXX this does not seem like a good thing to leave in SQL
- self.logger.infoPair("Calculating nDetections from", "n[filters]")
- for filter in filters:
+ #self.logger.infoPair("Calculating nDetections from", "n[filters]")
+ #for filter in filters:
# now do a sum of n[filters], but do not include the ones with -999
- sql = "UPDATE DiffDetObject "
- sql += "SET nDetections = nDetections + " + filter[1] +"nTotal "
- sql += " WHERE " + filter[1] + "nTotal != -999"
- try:
- self.scratchDb.execute(sql)
- except:
- self.logger.errorPair("failed sql", sql)
- return False
+ # sql = "UPDATE DiffDetObject "
+ # sql += "SET nDetections = nDetections + n" + filter[1]
+ # sql += " WHERE n" + filter[1] + " != -999"
+ # try:
+ # self.scratchDb.execute(sql)
+ # except:
+ # self.logger.errorPair("failed sql", sql)
+ # raise
+
@@ -223,5 +226,5 @@
except:
self.logger.errorPair("failed sql", sql)
- return False
+ raise
## use mean ra and dec (dec < 0)
@@ -241,5 +244,5 @@
except:
self.logger.errorPair("failed sql", sql)
- return False
+ raise
'''
@@ -261,5 +264,5 @@
except:
self.logger.errorPair("Couldn't squash out of range stuff", sql)
- return False
+ raise
self.logger.infoPair("setting to null > 1e-38 and < 1e-38 in", "cps FLUX_KRON")
@@ -270,5 +273,5 @@
except:
self.logger.errorPair("Couldn't squash out of range stuff", sql)
- return False
+ raise
@@ -288,5 +291,5 @@
sqlLine.group("batchID", "'" + str(self.batchID) + "'")
sqlLine.group("dvoRegionID", "CAT_ID")
- sqlLine.group("skycellID", "SKYCELL_ID")
+# sqlLine.group("skycellID", "SKYCELL_ID")
sqlLine.group("dataRelease", "'" + str(self.skychunk.dataRelease) + "'")
sqlLine.group("objInfoFlag", "FLAGS")
@@ -304,5 +307,5 @@
except:
self.logger.errorPair("Couldn't populate DiffDetObject table", sql)
- return False
+ raise
# add row count columns so we can perform joins to get colors
@@ -317,7 +320,8 @@
self.logger.infoPair("update DiffDetObject from ","cps table")
-
+ #this fills ng/etc
self.updateDiffObjectFromCps(cpsTableName)
-
+ #this fills qfperfect
+ self.updateMeanObjectFromCps(cpsTableName)
# XXX EAM 20140724 : is this necessary??
#objects can have out of range ra dec in dvo - need to find and kill them at the end
@@ -360,5 +364,5 @@
except:
self.logger.errorPair("Couldn't cull outsiders from DiffDetObject table", sql)
- return False
+ raise
self.logger.infoPair("Dropping row column from", "DiffDetObject table")
@@ -385,5 +389,5 @@
except:
self.logger.errorPair('failed sql',sql)
- return
+ raise
@@ -425,5 +429,5 @@
self.scratchDb.dropColumn("DiffDetObject", "row")
- self.dvoObjects.purgeRegion(self.region)
+ self.dvoDiffObjects.purgeRegion(self.region)
#this is abuse of something but this is how I get the object batches to crash to further investigate them
Index: /trunk/ippToPsps/jython/dvodiffobjects.py
===================================================================
--- /trunk/ippToPsps/jython/dvodiffobjects.py (revision 37926)
+++ /trunk/ippToPsps/jython/dvodiffobjects.py (revision 37927)
@@ -15,5 +15,5 @@
A class for ingesting DVO detections into MySQL
'''
-class DvoObjects(Dvo):
+class DvoDiffObjects(Dvo):
'''
@@ -22,5 +22,5 @@
def __init__(self, logger, config, skychunk, ippToPspsDb, scratchDb):
- super(DvoObjects, self).__init__(logger, config, skychunk, ippToPspsDb, scratchDb)
+ super(DvoDiffObjects, self).__init__(logger, config, skychunk, ippToPspsDb, scratchDb)
# declare DVO file types of interest
@@ -39,5 +39,5 @@
# TODO path to DVO prog hardcoded temporarily
- cmd = "dvopsps objects"
+ cmd = "dvopsps diffobj"
cmd += " -dbhost " + self.scratchDb.dbHost
cmd += " -dbname " + self.scratchDb.dbName
Index: /trunk/ippToPsps/jython/forcedobjectbatch.py
===================================================================
--- /trunk/ippToPsps/jython/forcedobjectbatch.py (revision 37926)
+++ /trunk/ippToPsps/jython/forcedobjectbatch.py (revision 37927)
@@ -25,5 +25,5 @@
'''
-class ForcedMeanObjectBatch(Batch):
+class ForcedObjectBatch(Batch):
'''
@@ -40,5 +40,5 @@
batchID):
- super(ForcedMeanObjectBatch, self).__init__(
+ super(ForcedObjectBatch, self).__init__(
logger,
config,
@@ -71,5 +71,5 @@
self.region = self.scratchDb.getRegionNameFromThisDvoIndex(self.id)
- self.ippToPspsDb.insertForcedMeanObjectMeta(self.batchID, self.region)
+ self.ippToPspsDb.insertForcedObjectMeta(self.batchID, self.region)
self.dvoForcedObjects.nativeIngestRegion(self.region)
@@ -86,4 +86,13 @@
return False
+ self.logger.infoPair("checking if we have anything in"," cpy/cpt")
+ rowcountcpt = self.scratchDb.getRowCount(cptTableName);
+ rowcountcpy = self.scratchDb.getRowCount(cpyTableName);
+ if (rowcountcpt == 0):
+ self.logger.infoPair("0 rows for ","cpt table")
+ return False
+ if (rowcountcpy == 0):
+ self.logger.infoPair("o rows for ","cpy table")
+ return False
return True
@@ -104,4 +113,19 @@
return True
+
+
+ '''
+ Updates table and generates pspsuniqueids
+ '''
+
+ def updatePspsUniqueIDs(self):
+ sql = "UPDATE ForcedMeanObject set uniquePspsFOid = (("+str(self.batchID)+"*1000000000 ) + row)"
+ try: self.scratchDb.execute(sql)
+ except:
+ self.logger.errorPair('failed sql',sql)
+ raise
+
+
+
'''
@@ -146,16 +170,16 @@
SET \
ForcedMeanObject." + filter[1] + "nTotal = NWARP \
- ,ForcedMeanObject." + filter[1] + "nIncPSFMag = NUSED_WRP \
- ,ForcedMeanObject." + filter[1] + "nIncKronMag = NUSED_KRON_WRP \
- ,ForcedMeanObject." + filter[1] + "nIncApMag = NUSED_AP_WRP \
- ,ForcedMeanObject." + filter[1] + "PSFMag = MAG_PSF_WRP \
- ,ForcedMeanObject." + filter[1] + "PSFMagErr = MAG_PSF_WRP_ERR \
- ,ForcedMeanObject." + filter[1] + "PSFMagStd = MAG_PSF_WRP_STD \
- ,ForcedMeanObject." + filter[1] + "KronMag = MAG_KRON_WRP \
- ,ForcedMeanObject." + filter[1] + "KronMagErr = MAG_KRON_WRP_ERR \
- ,ForcedMeanObject." + filter[1] + "KronMagStd = MAG_KRON_WRP_STD \
- ,ForcedMeanObject." + filter[1] + "ApMag = MAG_AP_WRP \
- ,ForcedMeanObject." + filter[1] + "ApMagErr = MAG_AP_WRP_ERR \
- ,ForcedMeanObject." + filter[1] + "ApMagStd = MAG_AP_WRP_STD \
+ ,ForcedMeanObject." + filter[1] + "nIncPSFFlux = NUSED_WRP \
+ ,ForcedMeanObject." + filter[1] + "nIncKronFlux = NUSED_KRON_WRP \
+ ,ForcedMeanObject." + filter[1] + "nIncApFlux = NUSED_AP_WRP \
+ ,ForcedMeanObject." + filter[1] + "PSFFlux = FLUX_PSF_WRP \
+ ,ForcedMeanObject." + filter[1] + "PSFFluxErr = FLUX_PSF_WRP_ERR \
+ ,ForcedMeanObject." + filter[1] + "PSFFluxStd = FLUX_PSF_WRP_STDEV \
+ ,ForcedMeanObject." + filter[1] + "KronFlux = FLUX_KRON_WRP \
+ ,ForcedMeanObject." + filter[1] + "KronFluxErr = FLUX_KRON_WRP_ERR \
+ ,ForcedMeanObject." + filter[1] + "KronFluxStd = FLUX_KRON_WRP_STDEV \
+ ,ForcedMeanObject." + filter[1] + "ApFlux = FLUX_AP_WRP \
+ ,ForcedMeanObject." + filter[1] + "ApFluxErr = FLUX_AP_WRP_ERR \
+ ,ForcedMeanObject." + filter[1] + "ApFluxStd = FLUX_AP_WRP_STDEV \
,ForcedMeanObject." + filter[1] + "Flags = FLAGS "
@@ -163,5 +187,5 @@
try: self.scratchDb.execute(sql)
except:
- self.logger.errorPair("failed update MeanObject", sql)
+ self.logger.errorPair("failed update ForcedMeanObject", sql)
raise
@@ -175,13 +199,17 @@
SET " + filter[1] + "PSFMagErr = null \
WHERE " + filter[1] + "PSFMagErr > " + str(cut)
- self.scratchDb.execute(sql)
-
+# taking out the cut since this is for mag, not flux
+
+ # try: self.scratchDb.execute(sql)
+ # except:
+ # self.logger.errorPair("failed setting null meanmagerr","ForcedMeanObject")
+ # raise
self.logger.infoPair("Calculating nDetections from", "n[filters]")
for filter in filters:
# now do a sum of n[filters], but do not include the ones with -999
- sql = "UPDATE ForcedMeanObject"
+ sql = "UPDATE ForcedMeanObject "
sql += "SET nDetections = nDetections + " + filter[1] +"nTotal "
- sql += " WHERE n" + filter[1] + " != -999"
- self.scratchDb.execute(sql)
+ sql += " WHERE " + filter[1] + "nTotal != -999"
+ #self.scratchDb.execute(sql)
try: self.scratchDb.execute(sql)
except:
@@ -192,5 +220,5 @@
Inserts stuff for all mags from the cpy files
'''
- def updateForcedMeanObjectFromCpy(self, cpyTable):
+ def updateForcedMeanTablesFromCpy(self, cpyTable):
# list of all filters PSPS is interested in
@@ -229,5 +257,5 @@
" + cpyTable + " AS cpy ON (cpy.row = (ForcedMeanObject.row* " + str(filterCount) + ")-(" + str(filterCount) + " - " + str(filter[0]) + ")) \
SET \
- ForcedMeanObject." + filter[1] + "nIncR5 = NMEAS \
+ ForcedMeanObject." + filter[1] + "nIncR5 = NMEAS \
,ForcedMeanObject." + filter[1] + "nIncR6 = NMEAS \
,ForcedMeanObject." + filter[1] + "FmeanflxR5 = FLUX_AP_R5 \
@@ -239,32 +267,40 @@
,ForcedMeanObject." + filter[1] + "FmeanflxR6Std = FLUX_STD_AP_R6 \
,ForcedMeanObject." + filter[1] + "FmeanflxR6Fill = FLUX_FIL_AP_R6 \
- ,ForcedMeanObject." + filter[1] + "LensObjSmearX11 = X11_SM_OBJ \
- ,ForcedMeanObject." + filter[1] + "LensObjSmearX12 = X12_SM_OBJ \
- ,ForcedMeanObject." + filter[1] + "LensObjSmearX22 = X22_SM_OBJ \
- ,ForcedMeanObject." + filter[1] + "LensObjSmearE1 = E1_SM_OBJ \
- ,ForcedMeanObject." + filter[1] + "LensObjSmearE2 = E2_SM_OBJ \
- ,ForcedMeanObject." + filter[1] + "LensObjShearX11 = X11_SH_OBJ \
- ,ForcedMeanObject." + filter[1] + "LensObjShearX12 = X12_SH_OBJ \
- ,ForcedMeanObject." + filter[1] + "LensObjShearX22 = X22_SH_OBJ \
- ,ForcedMeanObject." + filter[1] + "LensObjShearE1 = E1_SH_OBJ \
- ,ForcedMeanObject." + filter[1] + "LensObjShearE2 = E2_SH_OBJ \
- ,ForcedMeanObject." + filter[1] + "LensPSFSmearX11 = X11_SM_PSF \
- ,ForcedMeanObject." + filter[1] + "LensPSFSmearX12 = X12_SM_PSF \
- ,ForcedMeanObject." + filter[1] + "LensPSFSmearX22 = X22_SM_PSF \
- ,ForcedMeanObject." + filter[1] + "LensPSFSmearE1 = E1_SM_PSF \
- ,ForcedMeanObject." + filter[1] + "LensPSFSmearE2 = E2_SM_PSF \
- ,ForcedMeanObject." + filter[1] + "LensPSFShearX11 = X11_SH_PSF \
- ,ForcedMeanObject." + filter[1] + "LensPSFShearX12 = X12_SH_PSF \
- ,ForcedMeanObject." + filter[1] + "LensPSFShearX22 = X22_SH_PSF \
- ,ForcedMeanObject." + filter[1] + "LensPSFShearE1 = E1_SH_PSF \
- ,ForcedMeanObject." + filter[1] + "LensPSFShearE2 = E2_SH_PSF \
,ForcedMeanObject." + filter[1] + "Gamma = GAMMA \
,ForcedMeanObject." + filter[1] + "E1 = E1 \
,ForcedMeanObject." + filter[1] + "E2 = E2 "
-
try: self.scratchDb.execute(sql)
except:
- self.logger.errorPair("failed update on ForcedMeanObject using cpy table", sql)
+ self.logger.errorPair("failed update on ForcedMeanObject using cpy table",sql)
+ raise
+
+ sql = "UPDATE ForcedMeanLensing JOIN \
+ " + cpyTable + " AS cpy ON (cpy.row = (ForcedMeanLensing.row* " + str(filterCount) + ")-(" + str(filterCount) + " - " + str(filter[0]) + ")) \
+ SET \
+ ForcedMeanLensing." + filter[1] + "LensObjSmearX11 = X11_SM_OBJ \
+ ,ForcedMeanLensing." + filter[1] + "LensObjSmearX12 = X12_SM_OBJ \
+ ,ForcedMeanLensing." + filter[1] + "LensObjSmearX22 = X22_SM_OBJ \
+ ,ForcedMeanLensing." + filter[1] + "LensObjSmearE1 = E1_SM_OBJ \
+ ,ForcedMeanLensing." + filter[1] + "LensObjSmearE2 = E2_SM_OBJ \
+ ,ForcedMeanLensing." + filter[1] + "LensObjShearX11 = X11_SH_OBJ \
+ ,ForcedMeanLensing." + filter[1] + "LensObjShearX12 = X12_SH_OBJ \
+ ,ForcedMeanLensing." + filter[1] + "LensObjShearX22 = X22_SH_OBJ \
+ ,ForcedMeanLensing." + filter[1] + "LensObjShearE1 = E1_SH_OBJ \
+ ,ForcedMeanLensing." + filter[1] + "LensObjShearE2 = E2_SH_OBJ \
+ ,ForcedMeanLensing." + filter[1] + "LensPSFSmearX11 = X11_SM_PSF \
+ ,ForcedMeanLensing." + filter[1] + "LensPSFSmearX12 = X12_SM_PSF \
+ ,ForcedMeanLensing." + filter[1] + "LensPSFSmearX22 = X22_SM_PSF \
+ ,ForcedMeanLensing." + filter[1] + "LensPSFSmearE1 = E1_SM_PSF \
+ ,ForcedMeanLensing." + filter[1] + "LensPSFSmearE2 = E2_SM_PSF \
+ ,ForcedMeanLensing." + filter[1] + "LensPSFShearX11 = X11_SH_PSF \
+ ,ForcedMeanLensing." + filter[1] + "LensPSFShearX12 = X12_SH_PSF \
+ ,ForcedMeanLensing." + filter[1] + "LensPSFShearX22 = X22_SH_PSF \
+ ,ForcedMeanLensing." + filter[1] + "LensPSFShearE1 = E1_SH_PSF \
+ ,ForcedMeanLensing." + filter[1] + "LensPSFShearE2 = E2_SH_PSF "
+
+ try: self.scratchDb.execute(sql)
+ except:
+ self.logger.errorPair("failed update on ForcedMeanLensing using cpy table", sql)
raise
@@ -299,32 +335,65 @@
except:
self.logger.errorPair("Couldn't populate Object table from cpt", sql)
- return False
+ raise
# add row count columns so we can perform joins to get colors
- self.logger.infoPair("Adding 'row' columns to", "Object and cps tables")
+ self.logger.infoPair("Adding 'row' columns to", "Object ,cps, cpy tables")
self.scratchDb.addRowCountColumn("ForcedMeanObject", "row")
self.scratchDb.addRowCountColumn(cpsTableName, "row")
+ self.scratchDb.addRowCountColumn(cpyTableName, "row")
+
+ self.logger.infoPair("generating unique ids for ","ForcedMeanObject")
+ self.updatePspsUniqueIDs()
self.logger.infoPair("update ForcedMeanObject from ","cps table")
-
self.updateForcedMeanObjectFromCps(cpsTableName)
- self.logger.infoPair("update ForcedMeanObject from ","cpy table")
-
- self.updateForcedMeanObjectFromCpy(cpyTableName)
+ sqlLine = sqlUtility("INSERT INTO ForcedMeanLensing (")
+
+ sqlLine.group("objID", "objID")
+ sqlLine.group("uniquePspsFOid","uniquePspsFOid")
+ sqlLine.group("ippObjID", "ippObjID")
+ sqlLine.group("batchID", "batchID")
+ sqlLine.group("nDetections", "nDetections")
+ sqlLine.group("gStackID", "gStackID")
+ sqlLine.group("rStackID", "rStackID")
+ sqlLine.group("iStackID", "iStackID")
+ sqlLine.group("zStackID", "zStackID")
+ sqlLine.group("yStackID", "yStackID")
+
+ sql = sqlLine.makeRaw(") SELECT ", " FROM ForcedMeanObject")
+
+ try:
+ self.scratchDb.execute(sql)
+ except:
+ self.logger.errorPair("Couldn't populate ForcedMeanLensing table from ForcedMeanObject", sql)
+ raise
+
+ self.logger.infoPair("adding row to ","ForcedMeanLensing")
+ self.scratchDb.addRowCountColumn("ForcedMeanLensing", "row")
+
+ self.logger.infoPair("updating ForcedMeanObject and ForcedMeanLensing from ","cpy tables")
+ self.updateForcedMeanTablesFromCpy(cpyTableName)
self.logger.infoPair("Dropping row column from", "ForcedMeanObject table")
self.scratchDb.dropColumn("ForcedMeanObject", "row")
-
+ self.logger.infoPair("Dropping row column from", "ForcedMeanLensing table")
+ self.scratchDb.dropColumn("ForcedMeanLensing", "row")
##self.logger.infoPair("Purging from scratch Db", self.region + " region")
##Don't do this till after MeanObject
##self.dvoForcedObjects.purgeRegion(self.region)
-
+ self.logger.infoPair("setting minmaxobjid for ", "ForcedMeanObject table")
self.setMinMaxObjID(["ForcedMeanObject"])
-
- return True
+ self.logger.infoPair("checking if we have detctions", "FOrcedMeanObject table")
+ rowcount = self.scratchDb.getRowCount("ForcedMeanObject")
+ if rowcount == 0:
+ self.logger.infoPair("skipping this one","ForcedMeanObject ")
+ self.skipBatch = False
+ return True
+ else:
+ return True
Index: /trunk/ippToPsps/jython/loader.py
===================================================================
--- /trunk/ippToPsps/jython/loader.py (revision 37926)
+++ /trunk/ippToPsps/jython/loader.py (revision 37927)
@@ -28,5 +28,5 @@
#from forcedwarpbatch import ForcedWarpBatch
-#from forcedobjectbatch import ForcedObjectBatch
+from forcedobjectbatch import ForcedObjectBatch
#
#
@@ -168,6 +168,6 @@
self.logger.infoPair("Box dimensions: ", "ra / dec / size : %.1f / %.1f / %.1f -- sky bounds : (%.2f - %2.f, %2.f - %2.f)" % (boxDim['RA'], boxDim['DEC'], boxDim['SIDE'], boxDim['minRA'], boxDim['maxRA'], boxDim['minDEC'], boxDim['maxDEC']))
self.logger.infoPair(batchType + " items found in this box", "%d" % len(ids))
-
- if batchType != "OB":
+ #previously said if not OB, but we don't need these for Do or FO
+ if (batchType == "P2" or batchType == "ST" or batchType =="DF" or batchType == "FW"):
if self.config.resetDvo or not self.ippToPspsDb.isBoxIngested(boxId, self.scratchDb.dbHost):
if not self.dvoDetections.nativeIngestDetections(boxId, boxDim):