LSST Applications  21.0.0+04719a4bac,21.0.0-1-ga51b5d4+f5e6047307,21.0.0-11-g2b59f77+a9c1acf22d,21.0.0-11-ga42c5b2+86977b0b17,21.0.0-12-gf4ce030+76814010d2,21.0.0-13-g1721dae+760e7a6536,21.0.0-13-g3a573fe+768d78a30a,21.0.0-15-g5a7caf0+f21cbc5713,21.0.0-16-g0fb55c1+b60e2d390c,21.0.0-19-g4cded4ca+71a93a33c0,21.0.0-2-g103fe59+bb20972958,21.0.0-2-g45278ab+04719a4bac,21.0.0-2-g5242d73+3ad5d60fb1,21.0.0-2-g7f82c8f+8babb168e8,21.0.0-2-g8f08a60+06509c8b61,21.0.0-2-g8faa9b5+616205b9df,21.0.0-2-ga326454+8babb168e8,21.0.0-2-gde069b7+5e4aea9c2f,21.0.0-2-gecfae73+1d3a86e577,21.0.0-2-gfc62afb+3ad5d60fb1,21.0.0-25-g1d57be3cd+e73869a214,21.0.0-3-g357aad2+ed88757d29,21.0.0-3-g4a4ce7f+3ad5d60fb1,21.0.0-3-g4be5c26+3ad5d60fb1,21.0.0-3-g65f322c+e0b24896a3,21.0.0-3-g7d9da8d+616205b9df,21.0.0-3-ge02ed75+a9c1acf22d,21.0.0-4-g591bb35+a9c1acf22d,21.0.0-4-g65b4814+b60e2d390c,21.0.0-4-gccdca77+0de219a2bc,21.0.0-4-ge8a399c+6c55c39e83,21.0.0-5-gd00fb1e+05fce91b99,21.0.0-6-gc675373+3ad5d60fb1,21.0.0-64-g1122c245+4fb2b8f86e,21.0.0-7-g04766d7+cd19d05db2,21.0.0-7-gdf92d54+04719a4bac,21.0.0-8-g5674e7b+d1bd76f71f,master-gac4afde19b+a9c1acf22d,w.2021.13
LSST Data Management Base Package
repositoryMapper.py
Go to the documentation of this file.
1 #!/usr/bin/env python
2 
3 #
4 # LSST Data Management System
5 # Copyright 2016 LSST Corporation.
6 #
7 # This product includes software developed by the
8 # LSST Project (http://www.lsst.org/).
9 #
10 # This program is free software: you can redistribute it and/or modify
11 # it under the terms of the GNU General Public License as published by
12 # the Free Software Foundation, either version 3 of the License, or
13 # (at your option) any later version.
14 #
15 # This program is distributed in the hope that it will be useful,
16 # but WITHOUT ANY WARRANTY; without even the implied warranty of
17 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 # GNU General Public License for more details.
19 #
20 # You should have received a copy of the LSST License Statement and
21 # the GNU General Public License along with this program. If not,
22 # see <http://www.lsstcorp.org/LegalNotices/>.
23 #
24 
25 from lsst.daf.persistence import Mapper, ButlerLocation, Policy
26 
27 
29  """"Base class for a mapper to find repository configurations within a butler repository.
30 
31  .. warning::
32 
33  cfg is 'wet paint' and very likely to change. Use of it in production code other than via the 'old
34  butler' API is strongly discouraged.
35  """
36 
37  def __init__(self, storage, policy):
38  # todo I'm guessing the policy would probably want to come from the default in-package location, and
39  # then be overridden where desired by policy in repository root, and then
40  # have the cfg policy applied
41  self.policypolicy = Policy(policy)
42  self.storagestorage = storage
43 
44  def __repr__(self):
45  if 'policy' in self.__dict__ and 'storageCfg' in self.__dict__:
46  return 'RepositoryMapper(policy=%s, storageCfg=%s)' % (self.policypolicy, self.storageCfg)
47  else:
48  return 'uninitialized RepositoryMapper'
49 
50  def map_cfg(self, dataId, write):
51  """Map a location for a cfg file.
52 
53  :param dataId: keys & values to be applied to the template.
54  :param write: True if this map is being done do perform a write operation, else assumes read. Will
55  verify location exists if write is True.
56  :return: a butlerLocation that describes the mapped location.
57  """
58  # todo check: do we need keys to complete dataId? (search Registry)
59  template = self.policypolicy['repositories.cfg.template']
60  location = template % dataId
61  if not write and not self.storagestorage.exists(location):
62  return None
63  bl = ButlerLocation(
64  pythonType=self.policypolicy['repositories.cfg.python'],
65  cppType=None,
66  storageName=self.policypolicy['repositories.cfg.storage'],
67  locationList=(self.storagestorage.locationWithRoot(location),),
68  dataId=dataId,
69  mapper=self)
70  return bl
71 
72  def map_repo(self, dataId, write):
73  if write:
74  return None
75 
76  # todo check: do we need keys to complete dataId? (search Registry)
77 
78  template = self.policypolicy['repositories.repo.template']
79  location = template % dataId
80  if self.storagestorage.exists(location):
81  bl = ButlerLocation(
82  pythonType=self.policypolicy['repositories.repo.python'],
83  cppType=None,
84  storageName=None,
85  locationList=(location,),
86  dataId=dataId,
87  mapper=self)
88  return bl
89  return None