extern/podman-compose
1
0
Fork 1
mirror of https://github.com/containers/podman-compose.git synced 2025-04-14 04:28:38 +02:00
Code Issues Packages Projects Releases Wiki Activity

Add ability to input docker-compose.yaml via stdin

Browse Source 
Signed-off-by: Artho Pacini <eu@arthopacini.com>
This commit is contained in:
Artho Pacini 2024-06-16 14:25:02 -03:00 committed by Povilas Kanapickas
parent 14f39e5b86
commit 3359380ec6
1 changed files with 25 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
podman_compose.py
View File

@ -1762,7 +1762,7 @@ class PodmanCompose:
"pass files with -f" "pass files with -f"
) )
sys.exit(-1) sys.exit(-1)
ex = map(os.path.exists, files) ex = map(lambda x: x == '-' or os.path.exists(x), files)
missing = [fn0 for ex0, fn0 in zip(ex, files) if not ex0] missing = [fn0 for ex0, fn0 in zip(ex, files) if not ex0]
if missing: if missing:
log.fatal("missing files: %s", missing) log.fatal("missing files: %s", missing)
@ -1811,28 +1811,31 @@ class PodmanCompose:
except StopIteration: except StopIteration:
break break
with open(filename, "r", encoding="utf-8") as f: if filename.strip().split('/')[-1] == '-':
content = yaml.safe_load(f) content = yaml.safe_load(sys.stdin)
else:
with open(filename, "r", encoding="utf-8") as f:
content = yaml.safe_load(f)
# log(filename, json.dumps(content, indent = 2)) # log(filename, json.dumps(content, indent = 2))
if not isinstance(content, dict): if not isinstance(content, dict):
sys.stderr.write( sys.stderr.write(
"Compose file does not contain a top level object: %s\n" % filename "Compose file does not contain a top level object: %s\n" % filename
) )
sys.exit(1) sys.exit(1)
content = normalize(content) content = normalize(content)
# log(filename, json.dumps(content, indent = 2)) # log(filename, json.dumps(content, indent = 2))
content = rec_subs(content, self.environ) content = rec_subs(content, self.environ)
rec_merge(compose, content) rec_merge(compose, content)
# If `include` is used, append included files to files # If `include` is used, append included files to files
include = compose.get("include", None) include = compose.get("include", None)
if include: if include:
files.extend(include) files.extend(include)
# As compose obj is updated and tested with every loop, not deleting `include` # As compose obj is updated and tested with every loop, not deleting `include`
# from it, results in it being tested again and again, original values for # from it, results in it being tested again and again, original values for
# `include` be appended to `files`, and, included files be processed for ever. # `include` be appended to `files`, and, included files be processed for ever.
# Solution is to remove 'include' key from compose obj. This doesn't break # Solution is to remove 'include' key from compose obj. This doesn't break
# having `include` present and correctly processed in included files # having `include` present and correctly processed in included files
del compose["include"] del compose["include"]
resolved_services = self._resolve_profiles(compose.get("services", {}), set(args.profile)) resolved_services = self._resolve_profiles(compose.get("services", {}), set(args.profile))
compose["services"] = resolved_services compose["services"] = resolved_services
if not getattr(args, "no_normalize", None): if not getattr(args, "no_normalize", None):