diff mbox

[2/2] docker.py: Improve subprocess exit code handling

Message ID 20170712075528.22770-3-famz@redhat.com
State New
Headers show

Commit Message

Fam Zheng July 12, 2017, 7:55 a.m. UTC
A few error handlings are missing because we ignore the subprocess exit
code, for example "docker build" errors are currently ignored.

Introduce _do_check() aside the existing _do() method and use it in a
few places.

Signed-off-by: Fam Zheng <famz@redhat.com>
---
 tests/docker/docker.py | 19 ++++++++++++-------
 1 file changed, 12 insertions(+), 7 deletions(-)

Comments

Philippe Mathieu-Daudé July 12, 2017, 5:16 p.m. UTC | #1
On 07/12/2017 04:55 AM, Fam Zheng wrote:
> A few error handlings are missing because we ignore the subprocess exit
> code, for example "docker build" errors are currently ignored.
> 
> Introduce _do_check() aside the existing _do() method and use it in a
> few places.
> 
> Signed-off-by: Fam Zheng <famz@redhat.com>

Tested-by: Philippe Mathieu-Daudé <f4bug@amsat.org>

> ---
>   tests/docker/docker.py | 19 ++++++++++++-------
>   1 file changed, 12 insertions(+), 7 deletions(-)
> 
> diff --git a/tests/docker/docker.py b/tests/docker/docker.py
> index f5ac86b..ee40ca0 100755
> --- a/tests/docker/docker.py
> +++ b/tests/docker/docker.py
> @@ -117,6 +117,11 @@ class Docker(object):
>               kwargs["stdout"] = DEVNULL
>           return subprocess.call(self._command + cmd, **kwargs)
>   
> +    def _do_check(self, cmd, quiet=True, **kwargs):
> +        if quiet:
> +            kwargs["stdout"] = DEVNULL
> +        return subprocess.check_call(self._command + cmd, **kwargs)
> +
>       def _do_kill_instances(self, only_known, only_active=True):
>           cmd = ["ps", "-q"]
>           if not only_active:
> @@ -175,14 +180,14 @@ class Docker(object):
>                                       extra_files_cksum)))
>           tmp_df.flush()
>   
> -        self._do(["build", "-t", tag, "-f", tmp_df.name] + argv + \
> -                 [docker_dir],
> -                 quiet=quiet)
> +        self._do_check(["build", "-t", tag, "-f", tmp_df.name] + argv + \
> +                       [docker_dir],
> +                       quiet=quiet)
>   
>       def update_image(self, tag, tarball, quiet=True):
>           "Update a tagged image using "
>   
> -        self._do(["build", "-t", tag, "-"], quiet=quiet, stdin=tarball)
> +        self._do_check(["build", "-t", tag, "-"], quiet=quiet, stdin=tarball)
>   
>       def image_matches_dockerfile(self, tag, dockerfile):
>           try:
> @@ -195,9 +200,9 @@ class Docker(object):
>           label = uuid.uuid1().hex
>           if not keep:
>               self._instances.append(label)
> -        ret = self._do(["run", "--label",
> -                        "com.qemu.instance.uuid=" + label] + cmd,
> -                       quiet=quiet)
> +        ret = self._do_check(["run", "--label",
> +                             "com.qemu.instance.uuid=" + label] + cmd,
> +                             quiet=quiet)
>           if not keep:
>               self._instances.remove(label)
>           return ret
>
diff mbox

Patch

diff --git a/tests/docker/docker.py b/tests/docker/docker.py
index f5ac86b..ee40ca0 100755
--- a/tests/docker/docker.py
+++ b/tests/docker/docker.py
@@ -117,6 +117,11 @@  class Docker(object):
             kwargs["stdout"] = DEVNULL
         return subprocess.call(self._command + cmd, **kwargs)
 
+    def _do_check(self, cmd, quiet=True, **kwargs):
+        if quiet:
+            kwargs["stdout"] = DEVNULL
+        return subprocess.check_call(self._command + cmd, **kwargs)
+
     def _do_kill_instances(self, only_known, only_active=True):
         cmd = ["ps", "-q"]
         if not only_active:
@@ -175,14 +180,14 @@  class Docker(object):
                                     extra_files_cksum)))
         tmp_df.flush()
 
-        self._do(["build", "-t", tag, "-f", tmp_df.name] + argv + \
-                 [docker_dir],
-                 quiet=quiet)
+        self._do_check(["build", "-t", tag, "-f", tmp_df.name] + argv + \
+                       [docker_dir],
+                       quiet=quiet)
 
     def update_image(self, tag, tarball, quiet=True):
         "Update a tagged image using "
 
-        self._do(["build", "-t", tag, "-"], quiet=quiet, stdin=tarball)
+        self._do_check(["build", "-t", tag, "-"], quiet=quiet, stdin=tarball)
 
     def image_matches_dockerfile(self, tag, dockerfile):
         try:
@@ -195,9 +200,9 @@  class Docker(object):
         label = uuid.uuid1().hex
         if not keep:
             self._instances.append(label)
-        ret = self._do(["run", "--label",
-                        "com.qemu.instance.uuid=" + label] + cmd,
-                       quiet=quiet)
+        ret = self._do_check(["run", "--label",
+                             "com.qemu.instance.uuid=" + label] + cmd,
+                             quiet=quiet)
         if not keep:
             self._instances.remove(label)
         return ret