lsst.pipe.tasks.multiBandUtils Namespace Reference

Classes
class	MergeSourcesRunner
class	CullPeaksConfig
	More...

Functions
def	makeMergeArgumentParser (name, dataset)
	Create a suitable ArgumentParser. More...
def	getInputSchema (task, butler=None, schema=None)
	Obtain the input schema either directly or froma butler reference. More...
def	readCatalog (task, patchRef)
	Read input catalog. More...

Function Documentation

getInputSchema()

def lsst.pipe.tasks.multiBandUtils.getInputSchema	(		task,
			butler = None,
			schema = None
	)

Obtain the input schema either directly or froma butler reference.

Parameters

[in]	butler	butler reference to obtain the input schema from
[in]	schema	the input schema

Definition at line 146 of file multiBandUtils.py.

def getInputSchema(task, butler=None, schema=None):
    """!
    @brief Obtain the input schema either directly or froma  butler reference.
 
    @param[in]  butler   butler reference to obtain the input schema from
    @param[in]  schema   the input schema
    """
    if schema is None:
        assert butler is not None, "Neither butler nor schema specified"
        schema = butler.get(task.config.coaddName + "Coadd_" + task.inputDataset + "_schema",
                            immediate=True).schema
    return schema
 
 

makeMergeArgumentParser()

def lsst.pipe.tasks.multiBandUtils.makeMergeArgumentParser	(		name,
			dataset
	)

Create a suitable ArgumentParser.

We will use the ArgumentParser to get a provide a list of data references for patches; the RunnerClass will sort them into lists of data references for the same patch

Definition at line 131 of file multiBandUtils.py.

def makeMergeArgumentParser(name, dataset):
    """!
    @brief Create a suitable ArgumentParser.
 
    We will use the ArgumentParser to get a provide a list of data
    references for patches; the RunnerClass will sort them into lists
    of data references for the same patch
    """
    parser = ArgumentParser(name)
    parser.add_id_argument("--id", "deepCoadd_" + dataset,
                           ContainerClass=ExistingCoaddDataIdContainer,
                           help="data ID, e.g. --id tract=12345 patch=1,2 filter=g^r^i")
    return parser
 
 

readCatalog()

def lsst.pipe.tasks.multiBandUtils.readCatalog	(		task,
			patchRef
	)

Read input catalog.

We read the input dataset provided by the 'inputDataset' class variable.

Parameters

[in]

patchRef

data reference for patch

Returns

tuple consisting of the band name and the catalog

Definition at line 160 of file multiBandUtils.py.

def readCatalog(task, patchRef):
    """!
    @brief Read input catalog.
 
    We read the input dataset provided by the 'inputDataset'
    class variable.
 
    @param[in]  patchRef   data reference for patch
    @return tuple consisting of the band name and the catalog
    """
    band = patchRef.get(task.config.coaddName + "Coadd_filterLabel", immediate=True).bandLabel
    catalog = patchRef.get(task.config.coaddName + "Coadd_" + task.inputDataset, immediate=True)
    task.log.info("Read %d sources for band %s: %s", len(catalog), band, patchRef.dataId)
    return band, catalog