lsst.pipe.tasks.ingest.RegisterTask Class Reference

Inheritance diagram for lsst.pipe.tasks.ingest.RegisterTask:

Public Member Functions
def	openRegistry (self, directory, create=False, dryrun=False, name="registry.sqlite3")
def	createTable (self, conn, table=None, forceCreateTables=False)
def	check (self, conn, info, table=None)
def	addRow (self, conn, info, dryrun=False, create=False, table=None)

Static Public Attributes
	ConfigClass = RegisterConfig
string	placeHolder = '?'
dictionary	typemap = {'text': str, 'int': int, 'double': float}

Detailed Description

Task that will generate the registry for the Mapper

Definition at line 280 of file ingest.py.

Member Function Documentation

addRow()

def lsst.pipe.tasks.ingest.RegisterTask.addRow	(		self,
			conn,
			info,
			dryrun = False,
			create = False,
			table = None
	)

Add a row to the file table (typically 'raw').

@param conn    Database connection
@param info    File properties to add to database
@param table   Name of table in database

Reimplemented in lsst.pipe.tasks.ingestCalibs.CalibsRegisterTask.

Definition at line 359 of file ingest.py.

check()

def lsst.pipe.tasks.ingest.RegisterTask.check	(		self,
			conn,
			info,
			table = None
	)

Check for the presence of a row already

Not sure this is required, given the 'ignore' configuration option.

Definition at line 340 of file ingest.py.

createTable()

def lsst.pipe.tasks.ingest.RegisterTask.createTable	(		self,
			conn,
			table = None,
			forceCreateTables = False
	)

Create the registry tables

One table (typically 'raw') contains information on all files, and the
other (typically 'raw_visit') contains information on all visits.

@param conn    Database connection
@param table   Name of table to create in database

Reimplemented in lsst.pipe.tasks.ingestCalibs.CalibsRegisterTask, and lsst.pipe.tasks.ingestPgsql.PgsqlRegisterTask.

Definition at line 302 of file ingest.py.

openRegistry()

def lsst.pipe.tasks.ingest.RegisterTask.openRegistry	(		self,
			directory,
			create = False,
			dryrun = False,
			name = "registry.sqlite3"
	)

Open the registry and return the connection handle.

@param directory  Directory in which the registry file will be placed
@param create  Clobber any existing registry and create a new one?
@param dryrun  Don't do anything permanent?
@param name    Filename of the registry
@return Database connection

Reimplemented in lsst.pipe.tasks.ingestPgsql.PgsqlRegisterTask, and lsst.pipe.tasks.ingestCalibs.CalibsRegisterTask.

Definition at line 286 of file ingest.py.

Member Data Documentation

ConfigClass

lsst.pipe.tasks.ingest.RegisterTask.ConfigClass = RegisterConfig

static

Definition at line 282 of file ingest.py.

placeHolder

string lsst.pipe.tasks.ingest.RegisterTask.placeHolder = '?'

static

Definition at line 283 of file ingest.py.

typemap

dictionary lsst.pipe.tasks.ingest.RegisterTask.typemap = {'text': str, 'int': int, 'double': float}

static

Definition at line 284 of file ingest.py.

---

The documentation for this class was generated from the following file:

• python/lsst/pipe/tasks/ingest.py