Skip to content

Commit

Permalink
Use apdb_marker to test for association completion.
Browse files Browse the repository at this point in the history
This should be faster (and is definitely simpler) than loading
VisitInfo and querying the database directly.
  • Loading branch information
kfindeisen committed Nov 20, 2019
1 parent 2005124 commit be0dbc2
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions python/lsst/ap/pipe/ap_pipe.py
Original file line number Diff line number Diff line change
Expand Up @@ -209,8 +209,7 @@ def runDataRef(self, rawRef, templateIds=None, reuse=None):
"matters, please clear the association database and run "
"ap_pipe.py with --reuse-output-from=differencer to redo all "
"association results consistently.")
if "associator" in reuse and \
self.apdb.isVisitProcessed(calexpRef.get("calexp_visitInfo")):
if "associator" in reuse and calexpRef.datasetExists("apdb_marker", write=True):
message = "Association has already been run for {0}, skipping...".format(calexpRef.dataId)
self.log.info(message)
associationResults = None
Expand Down

0 comments on commit be0dbc2

Please sign in to comment.