diff --git a/lib/ansible/executor/task_queue_manager.py b/lib/ansible/executor/task_queue_manager.py index 19996892a0..b11b6a674f 100644 --- a/lib/ansible/executor/task_queue_manager.py +++ b/lib/ansible/executor/task_queue_manager.py @@ -22,7 +22,6 @@ __metaclass__ = type import multiprocessing import os import socket -import sys import tempfile from ansible import constants as C @@ -83,12 +82,6 @@ class TaskQueueManager: self._final_q = multiprocessing.Queue() - # create the pool of worker threads, based on the number of forks specified - try: - fileno = sys.stdin.fileno() - except ValueError: - fileno = None - # A temporary file (opened pre-fork) used by connection # plugins for inter-process locking. self._connection_lockfile = tempfile.TemporaryFile()