diff --git a/test/integration/test_transmit_worker_process.py b/test/integration/test_transmit_worker_process.py
index <HASH>..<HASH> 100644
--- a/test/integration/test_transmit_worker_process.py
+++ b/test/integration/test_transmit_worker_process.py
@@ -75,11 +75,12 @@ def test_remote_job_interface(tmpdir, test_data_dir, job_type):
             events.append(json.loads(content))
     stdout = '\n'.join(event['stdout'] for event in events)
 
-    if 'job_type' == 'run':
+    if job_type == 'run':
         assert 'Hello world!' in stdout
     else:
         assert '"ansible_facts"' in stdout
 
+
 def test_missing_private_dir_transmit(tmpdir):
     outgoing_buffer = io.BytesIO()
Fix test conditional, should be passing now