Do not transmit the private_data_dir to the worker

ansible · Oct 7, 2020 · 65cb34e · 65cb34e
1 parent cf8e8cb
commit 65cb34e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/ansible_runner/streaming.py b/ansible_runner/streaming.py
@@ -36,6 +36,7 @@ def __init__(self, _output=None, **kwargs):
         if _output is None:
             _output = sys.stdout.buffer
         self._output = _output
+        self.private_data_dir = kwargs.pop('private_data_dir')
         self.kwargs = kwargs
 
         self.status = "unstarted"
@@ -48,8 +49,7 @@ def run(self):
         self._output.write(b'\n')
         self._output.flush()
 
-        private_data_dir = self.kwargs.get('private_data_dir')
-        self._output.write(utils.stream_dir(private_data_dir))
+        self._output.write(utils.stream_dir(self.private_data_dir))
         self._output.write(json.dumps({'eof': True}).encode('utf-8'))
         self._output.write(b'\n')
         self._output.flush()