diff options
| -rw-r--r-- | cloudinit/mergers/__init__.py | 11 | ||||
| -rw-r--r-- | cloudinit/mergers/m_dict.py (renamed from cloudinit/mergers/dict.py) | 0 | ||||
| -rw-r--r-- | cloudinit/mergers/m_list.py (renamed from cloudinit/mergers/list.py) | 0 | ||||
| -rw-r--r-- | cloudinit/mergers/m_str.py (renamed from cloudinit/mergers/str.py) | 0 |
4 files changed, 8 insertions, 3 deletions
diff --git a/cloudinit/mergers/__init__.py b/cloudinit/mergers/__init__.py index e1ff57ba..f504e15f 100644 --- a/cloudinit/mergers/__init__.py +++ b/cloudinit/mergers/__init__.py @@ -26,6 +26,8 @@ NAME_MTCH = re.compile(r"(^[a-zA-Z_][A-Za-z0-9_]*)\((.*?)\)$") LOG = logging.getLogger(__name__) DEF_MERGE_TYPE = "list()+dict()+str()" +MERGER_PREFIX = 'm_' +MERGER_ATTR = 'Merger' class UnknownMerger(object): @@ -136,15 +138,18 @@ def default_mergers(): def construct(parsed_mergers): mergers_to_be = [] for (m_name, m_ops) in parsed_mergers: + if not m_name.startswith(MERGER_PREFIX): + m_name = MERGER_PREFIX + str(m_name) merger_locs = importer.find_module(m_name, [__name__], - ['Merger']) + [MERGER_ATTR]) if not merger_locs: - msg = "Could not find merger named '%s'" % (m_name) + msg = ("Could not find merger module named '%s' " + "with attribute '%s'") % (m_name, MERGER_ATTR) raise ImportError(msg) else: mod = importer.import_module(merger_locs[0]) - mod_attr = getattr(mod, 'Merger') + mod_attr = getattr(mod, MERGER_ATTR) mergers_to_be.append((mod_attr, m_ops)) # Now form them... mergers = [] diff --git a/cloudinit/mergers/dict.py b/cloudinit/mergers/m_dict.py index 45a7d3a5..45a7d3a5 100644 --- a/cloudinit/mergers/dict.py +++ b/cloudinit/mergers/m_dict.py diff --git a/cloudinit/mergers/list.py b/cloudinit/mergers/m_list.py index a56ff007..a56ff007 100644 --- a/cloudinit/mergers/list.py +++ b/cloudinit/mergers/m_list.py diff --git a/cloudinit/mergers/str.py b/cloudinit/mergers/m_str.py index 291c91c2..291c91c2 100644 --- a/cloudinit/mergers/str.py +++ b/cloudinit/mergers/m_str.py |