diff --git a/test/rmq/test_process_comms.py b/test/rmq/test_process_comms.py index 3cfd69e5..67190ce6 100644 --- a/test/rmq/test_process_comms.py +++ b/test/rmq/test_process_comms.py @@ -175,7 +175,7 @@ def test_play(self): self.assertTrue(proc.pause()) # Send a play message - play_future = self.process_controller.pause_process(proc.pid) + play_future = self.process_controller.play_process(proc.pid) # Allow the process to respond to the request result = yield play_future @@ -187,8 +187,8 @@ def test_play(self): def test_kill(self): proc = test_utils.WaitForSignalProcess(communicator=self.communicator) - # Send a play message - kill_future = self.process_controller.kill_process(proc.pid) + # Send a kill message + kill_future = yield self.process_controller.kill_process(proc.pid) # Allow the process to respond to the request result = yield kill_future