Skip to content

Commit

Permalink
Responded to some reviewer comments
Browse files Browse the repository at this point in the history
Stashing current commits to rebase to master.
  • Loading branch information
morriscb committed Sep 7, 2017
1 parent 8279cee commit be734d4
Showing 1 changed file with 9 additions and 8 deletions.
17 changes: 9 additions & 8 deletions python/lsst/ap/association/assoc_db_sqlite.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,8 +29,10 @@
import lsst.afw.geom as afwGeom
import lsst.pex.config as pexConfig
import lsst.pipe.base as pipeBase
from .dia_collection import *
from .dia_object import *
from .dia_collection import DIAObjectCollection
from .dia_object import DIAObject, \
make_minimal_dia_object_schema, \
make_minimal_dia_source_schema


__all__ = ["AssociationDBSqliteConfig", "AssociationDBSqliteTask"]
Expand Down Expand Up @@ -108,20 +110,19 @@ class AssociationDBSqliteTask(pipeBase.Task):
_DefaultName = "association_db_sqlite"

def __init__(self, **kwargs):
""" Create a new connection to the sqlite database specified in
the config.
"""

pipeBase.Task.__init__(self, **kwargs)
self.indexer = IndexerRegistry[self.config.indexer.name](
self.config.indexer.active)
self._db_connection = sqlite3.connect(self.config.db_name)
self._db_cursor = self._db_connection.cursor()

def run(self):
""" Not implemented in this subtask. Please use the store and load
methods.
""" This subtask does not make use of the run method for Tasks.
Please use the store or load methods.
"""
Raise(NotImplementedError)
return None

def commit(self):
""" Save changes to the sqlite database.
Expand Down

0 comments on commit be734d4

Please sign in to comment.