LSSTApplications  17.0+49,17.0+83,17.0+9,18.0.0+13,18.0.0+16,18.0.0+2,18.0.0+28,18.0.0+4,18.0.0+9,18.0.0-2-ge43143a+4,18.1.0-1-g0001055,18.1.0-1-g0896a44+4,18.1.0-1-g1349e88+3,18.1.0-1-g2505f39+2,18.1.0-1-g380d4d4+3,18.1.0-1-g5e4b7ea,18.1.0-1-g85f8cd4+2,18.1.0-1-g9a6769a+1,18.1.0-1-ga1a4c1a+1,18.1.0-1-gc037db8,18.1.0-1-ge10677a+2,18.1.0-10-g73b8679e+5,18.1.0-11-g311e899+2,18.1.0-11-gf570990de,18.1.0-12-gc95f69a+2,18.1.0-2-g000ad9a+2,18.1.0-2-g31c43f9+2,18.1.0-2-g9c63283+3,18.1.0-2-gdf0b915+3,18.1.0-2-gf03bb23,18.1.0-3-g2e29e3d+4,18.1.0-3-g52aa583+1,18.1.0-3-g9cb968e+2,18.1.0-4-gd2e8982+4,18.1.0-5-g510c42a+2,18.1.0-5-gaeab27e+3,18.1.0-6-gdda7f3e+4,18.1.0-7-g89824ecc+3,w.2019.32
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)