stop job test

Author: cunla

scheduler/tests/test_worker/test_worker_commands.py

@@ -62,12 +62,12 @@ def test_stop_job_command__success(self):
         command = StopJobCommand(worker_name=worker_name, job_name=job.name)
         command_payload = json.dumps(command.command_payload())
         worker._command_listener.handle_payload(dict(data=command_payload))
-        worker.monitor_job_execution_process(job,queue)
+        worker.monitor_job_execution_process(job, queue)
 
         # Assert
         job = JobModel.get(job.name, connection=queue.connection)
         worker = WorkerModel.get(worker.name, connection=queue.connection)
         self.assertEqual(worker.stopped_job_name, job.name)
         self.assertIsNone(worker.current_job_name)
         self.assertEqual(job.status, JobStatus.STOPPED)
-        t.join()
+        t.join()