Get test running to finish

ansible_runner/streaming.py

@@ -200,10 +200,10 @@ def event_callback(self, event_data):
     def artifacts_callback(self, artifacts_data):
         buf = io.BytesIO(artifacts_data)
         with zipfile.ZipFile(buf, 'r') as archive:
-            archive.extractall(path=self.config.artifact_dir)
+            archive.extractall(path=self.artifact_dir)
 
         if self.artifacts_handler is not None:
-            self.artifacts_handler(self.config.artifact_dir)
+            self.artifacts_handler(self.artifact_dir)
 
     def run(self):
         job_events_path = os.path.join(self.artifact_dir, 'job_events')

test/integration/test_transmit_worker_process.py

@@ -4,13 +4,6 @@
 from ansible_runner.streaming import Transmitter, Worker, Processor
 
 
-def peek_contents(buffer):
-    pos = buffer.tell()
-    content = buffer.read()
-    buffer.seek(pos)
-    return content
-
-
 def test_remote_job_interface(tmpdir, test_data_dir):
     worker_dir = str(tmpdir.mkdir('for_worker'))
     process_dir = str(tmpdir.mkdir('for_process'))
@@ -35,7 +28,7 @@ def test_remote_job_interface(tmpdir, test_data_dir):
 
     outgoing_buffer.seek(0)  # rewind so we can start reading
 
-    sent = peek_contents(outgoing_buffer)
+    sent = outgoing_buffer.getvalue()
     assert sent  # should not be blank at least
     assert b'zipfile' in sent
 
@@ -58,4 +51,4 @@ def test_remote_job_interface(tmpdir, test_data_dir):
     )
     processor.run()
 
-    assert os.listdir(process_dir) == ['project', 'artifacts'], outgoing_buffer.getvalue()
+    assert set(os.listdir(process_dir)) == set(['artifacts']), outgoing_buffer.getvalue()