LSSTApplications  18.1.0
LSSTDataManagementBasePackage
Functions
lsst.dax.ppdb.ap_verify_queries Namespace Reference

Functions

def countUnassociatedObjects (ppdb)
 
def isVisitProcessed (ppdb, visitInfo)
 

Function Documentation

◆ countUnassociatedObjects()

def lsst.dax.ppdb.ap_verify_queries.countUnassociatedObjects (   ppdb)
Return the number of DiaObjects that have only one DiaSource associated
with them.

Parameters
----------
ppdb : `lsst.dax.ppdb.Ppdb`
    Ppdb object connected to an instantiated database.

Returns
-------
count : `int`
    Number of DiaObjects with exactly one associated DiaSource.

Definition at line 31 of file ap_verify_queries.py.

31 def countUnassociatedObjects(ppdb):
32  """Return the number of DiaObjects that have only one DiaSource associated
33  with them.
34 
35  Parameters
36  ----------
37  ppdb : `lsst.dax.ppdb.Ppdb`
38  Ppdb object connected to an instantiated database.
39 
40  Returns
41  -------
42  count : `int`
43  Number of DiaObjects with exactly one associated DiaSource.
44  """
45  # Retrieve the DiaObject table.
46  table = ppdb._schema.objects
47 
48  # Construct the sql statement.
49  stmt = sql.select([func.count()]).select_from(table).where(table.c.nDiaSources == 1)
50  stmt = stmt.where(table.c.validityEnd == None) # noqa: E711
51 
52  # Return the count.
53  count = ppdb._engine.scalar(stmt)
54 
55  return count
56 
57 

◆ isVisitProcessed()

def lsst.dax.ppdb.ap_verify_queries.isVisitProcessed (   ppdb,
  visitInfo 
)
Test whether data from an image has been loaded into the database.

Parameters
----------
ppdb : `lsst.dax.ppdb.Ppdb`
    Ppdb object connected to an instantiated database.
visitInfo : `lsst.afw.image.VisitInfo`
    The metadata for the image of interest.

Returns
-------
isProcessed : `bool`
    `True` if the data are present, `False` otherwise.

Definition at line 58 of file ap_verify_queries.py.

58 def isVisitProcessed(ppdb, visitInfo):
59  """Test whether data from an image has been loaded into the database.
60 
61  Parameters
62  ----------
63  ppdb : `lsst.dax.ppdb.Ppdb`
64  Ppdb object connected to an instantiated database.
65  visitInfo : `lsst.afw.image.VisitInfo`
66  The metadata for the image of interest.
67 
68  Returns
69  -------
70  isProcessed : `bool`
71  `True` if the data are present, `False` otherwise.
72  """
73  id = visitInfo.getExposureId()
74  table = ppdb._schema.sources
75  idField = table.c.ccdVisitId
76 
77  # Hopefully faster than SELECT DISTINCT
78  query = sql.select([idField]).select_from(table) \
79  .where(idField == id).limit(1)
80 
81  return ppdb._engine.scalar(query) is not None
82 
def isVisitProcessed(ppdb, visitInfo)