ben/podlaunch
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

Add option stopping previous pods, defaults to yes

Browse source
This commit is contained in:
Benedikt Ziemons 2020-11-19 00:45:50 +01:00
parent 6bea5f72e0
commit 5338563299
Signed by: ben
GPG key ID: 0F54A7ED232D3319
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
main.py
View file

@ -18,8 +18,9 @@ sdnotify = sh.Command("systemd-notify")
class PodKeeper: class PodKeeper:
def __init__(self, network, identifier): def __init__(self, network, stop_previous, identifier):
self.podnet_args = ("--network", network) if network else () self.podnet_args = ("--network", network) if network else ()
self.stop_previous = stop_previous
identifier_path = pathlib.PurePath(identifier) identifier_path = pathlib.PurePath(identifier)
if len(identifier_path.parts) != 1: if len(identifier_path.parts) != 1:
raise ValueError(f"identifier has path parts: {identifier_path}") raise ValueError(f"identifier has path parts: {identifier_path}")
@ -53,6 +54,10 @@ class PodKeeper:
def run(self): def run(self):
os.chdir(self.podhome) os.chdir(self.podhome)
if self.stop_previous and podman.pod.exists(self.podname).exit_code == 0:
print(f"Stopping pod {self.podname}", file=sys.stderr, flush=True)
podman.pod.stop(self.podname)
print(f"Starting pod {self.podname} at {self.last_check}", file=sys.stderr, flush=True) print(f"Starting pod {self.podname} at {self.last_check}", file=sys.stderr, flush=True)
podman.play.kube(self.podyaml, *self.podnet_args) podman.play.kube(self.podyaml, *self.podnet_args)
try: try:
@ -117,9 +122,10 @@ class PodKeeper:
@click.command() @click.command()
@click.option("--network", default="brodge", help="Network for the created pod") @click.option("--network", default="brodge", help="Network for the created pod")
@click.option("--stop-previous", default=True, help="Stop previously running pod with the same name")
@click.argument("identifier") @click.argument("identifier")
def main(network, identifier): def main(network, stop_previous, identifier):
keeper = PodKeeper(network, identifier) keeper = PodKeeper(network, stop_previous, identifier)
signal(SIGINT, keeper.destroy) signal(SIGINT, keeper.destroy)
signal(SIGTERM, keeper.destroy) signal(SIGTERM, keeper.destroy)