LSSTApplications  17.0+11,17.0+34,17.0+56,17.0+57,17.0+59,17.0+7,17.0-1-g377950a+33,17.0.1-1-g114240f+2,17.0.1-1-g4d4fbc4+28,17.0.1-1-g55520dc+49,17.0.1-1-g5f4ed7e+52,17.0.1-1-g6dd7d69+17,17.0.1-1-g8de6c91+11,17.0.1-1-gb9095d2+7,17.0.1-1-ge9fec5e+5,17.0.1-1-gf4e0155+55,17.0.1-1-gfc65f5f+50,17.0.1-1-gfc6fb1f+20,17.0.1-10-g87f9f3f+1,17.0.1-11-ge9de802+16,17.0.1-16-ga14f7d5c+4,17.0.1-17-gc79d625+1,17.0.1-17-gdae4c4a+8,17.0.1-2-g26618f5+29,17.0.1-2-g54f2ebc+9,17.0.1-2-gf403422+1,17.0.1-20-g2ca2f74+6,17.0.1-23-gf3eadeb7+1,17.0.1-3-g7e86b59+39,17.0.1-3-gb5ca14a,17.0.1-3-gd08d533+40,17.0.1-30-g596af8797,17.0.1-4-g59d126d+4,17.0.1-4-gc69c472+5,17.0.1-6-g5afd9b9+4,17.0.1-7-g35889ee+1,17.0.1-7-gc7c8782+18,17.0.1-9-gc4bbfb2+3,w.2019.22
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)