Merge "Use threads instead of processes in zuul_stream" into feature/zuulv3
diff --git a/zuul/ansible/callback/zuul_stream.py b/zuul/ansible/callback/zuul_stream.py
index 260f4ab..2068925 100644
--- a/zuul/ansible/callback/zuul_stream.py
+++ b/zuul/ansible/callback/zuul_stream.py
@@ -14,10 +14,10 @@
# along with Ansible. If not, see <http://www.gnu.org/licenses/>.
import datetime
-import multiprocessing
import logging
import os
import socket
+import threading
import time
import uuid
@@ -161,7 +161,7 @@
'ansible_host', play_vars[host].get(
'ansible_inventory_host'))
self._host_dict[host] = ip
- self._streamer = multiprocessing.Process(
+ self._streamer = threading.Thread(
target=self._read_log, args=(host, ip, log_id, task_name))
self._streamer.daemon = True
self._streamer.start()