From 294e43ba2f659f021933378ddf6e1f51b8cf7f74 Mon Sep 17 00:00:00 2001 From: Michael DeHaan Date: Sat, 23 Feb 2013 13:47:11 -0500 Subject: [PATCH] Removing pipe once since it has some issues about evaluating more than once :) --- .../runner/lookup_plugins/pipe_once.py | 46 ------------------- 1 file changed, 46 deletions(-) delete mode 100644 lib/ansible/runner/lookup_plugins/pipe_once.py diff --git a/lib/ansible/runner/lookup_plugins/pipe_once.py b/lib/ansible/runner/lookup_plugins/pipe_once.py deleted file mode 100644 index eb320a4713..0000000000 --- a/lib/ansible/runner/lookup_plugins/pipe_once.py +++ /dev/null @@ -1,46 +0,0 @@ -# (c) 2012, Daniel Hokka Zakrisson -# -# This file is part of Ansible -# -# Ansible is free software: you can redistribute it and/or modify -# it under the terms of the GNU General Public License as published by -# the Free Software Foundation, either version 3 of the License, or -# (at your option) any later version. -# -# Ansible is distributed in the hope that it will be useful, -# but WITHOUT ANY WARRANTY; without even the implied warranty of -# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -# GNU General Public License for more details. -# -# You should have received a copy of the GNU General Public License -# along with Ansible. If not, see . - -import subprocess -from ansible import utils, errors - -CACHE = {} - -class LookupModule(object): - - def __init__(self, basedir=None, **kwargs): - self.basedir = basedir - - def run(self, terms, **kwargs): - - - if isinstance(terms, basestring): - terms = [ terms ] - ret = [] - for term in terms: - if term in CACHE: - ret.append(CACHE.get(term)) - continue - p = subprocess.Popen(term, cwd=self.basedir, shell=True, stdin=subprocess.PIPE, stdout=subprocess.PIPE) - (stdout, stderr) = p.communicate() - if p.returncode == 0: - result = stdout.strip() - CACHE[term] = result - ret.append(result) - else: - raise errors.AnsibleError("lookup_plugin.pipe(%s) returned %d" % (term, p.returncode)) - return ret