commit bec0e0d803c0cbde32c48e1ebadbc8b9558b8a60
author Zuul <zuul@review.openstack.org> Mon Sep 04 00:02:35 2017 +0000
committer Gerrit Code Review <review@openstack.org> Mon Sep 04 00:02:35 2017 +0000
tree 728a7c6f9ceb47224686ec1b48998dfae31d1624
parent d6d0f58988f426924917ec3fd8149eb9d5c4ee56
parent 974fe0ddbcd9b7eac6cac4324920448cc6902cdb

Merge "Support IPv6 with zuul_stream" into feature/zuulv3

zuul/ansible/callback/zuul_stream.py

diff --git a/zuul/ansible/callback/zuul_stream.py b/zuul/ansible/callback/zuul_stream.py
index 906f052..6aec86b 100644
--- a/zuul/ansible/callback/zuul_stream.py
+++ b/zuul/ansible/callback/zuul_stream.py
@@ -134,10 +134,9 @@
     def _read_log(self, host, ip, log_id, task_name, hosts):
         self._log("[%s] Starting to log %s for task %s"
                   % (host, log_id, task_name), job=False, executor=True)
-        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
         while True:
             try:
-                s.connect((ip, LOG_STREAM_PORT))
+                s = socket.create_connection((ip, LOG_STREAM_PORT))
             except Exception:
                 self._log("[%s] Waiting on logger" % host,
                           executor=True, debug=True)