lsst.pipe.tasks.ingest.RegistryContext Class Reference

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

Public Member Functions
def	__init__
def	__enter__
def	__exit__

Public Attributes
	registryName
	permissions
	updateName
	conn

Detailed Description

Context manager to provide a registry

An existing registry is copied, so that it may continue
to be used while we add to this new registry.  Finally,
the new registry is moved into the right place.

Definition at line 186 of file ingest.py.

Constructor & Destructor Documentation

def lsst.pipe.tasks.ingest.RegistryContext.__init__	(		self,
			registryName,
			createTableFunc,
			forceCreateTables,
			permissions
	)

Construct a context manager

@param registryName: Name of registry file
@param createTableFunc: Function to create tables

Definition at line 193 of file ingest.py.

    def __init__(self, registryName, createTableFunc, forceCreateTables, permissions):
        """Construct a context manager

        @param registryName: Name of registry file
        @param createTableFunc: Function to create tables
        """
        self.registryName = registryName
        self.permissions = permissions

        updateFile = tempfile.NamedTemporaryFile(prefix=registryName, dir=os.path.dirname(self.registryName),
                                                 delete=False)
        self.updateName = updateFile.name

        haveTable = False
        if os.path.exists(registryName):
            assertCanCopy(registryName, self.updateName)
            os.chmod(self.updateName, os.stat(registryName).st_mode)
            shutil.copyfile(registryName, self.updateName)
            haveTable = True

        self.conn = sqlite3.connect(self.updateName)
        if not haveTable or forceCreateTables:
            createTableFunc(self.conn)
        os.chmod(self.updateName, self.permissions)