Raise DockerException when encountering non-JSON chunk in stream_helper1222-diagnostic

Signed-off-by: Joffrey F <joffrey@docker.com>

1 files changed, 6 insertions, 1 deletions

diff --git a/docker/client.py b/docker/client.py
index 47ad09e..c013849 100644
--- a/docker/client.py
+++ b/docker/client.py
@@ -256,7 +256,12 @@ class Client(
                     data_list = data.split("\r\n")
                     # load and yield each line seperately
                     for data in data_list:
-                        data = json.loads(data)
+                        try:
+                            data = json.loads(data)
+                        except Exception:
+                            raise errors.DockerException(
+                                '"{0}" is not valid JSON.'
+                            )
                         yield data
                 else:
                     yield data