diff --git a/awx/main/management/commands/replay_job_events.py b/awx/main/management/commands/replay_job_events.py index 2925e47606..68634092f6 100644 --- a/awx/main/management/commands/replay_job_events.py +++ b/awx/main/management/commands/replay_job_events.py @@ -194,7 +194,8 @@ class ReplayJobEvents(JobStatusLifeCycle): je_previous = je_current if n == finish_status_index: - self.sleep(final_status_delay) + if final_status_delay != 0: + self.sleep(final_status_delay) self.emit_job_status(job, job.status) if stats['events_total'] > 2: diff --git a/awx/main/tests/unit/commands/test_replay_job_events.py b/awx/main/tests/unit/commands/test_replay_job_events.py index 1031e55b4b..36b668a7bf 100644 --- a/awx/main/tests/unit/commands/test_replay_job_events.py +++ b/awx/main/tests/unit/commands/test_replay_job_events.py @@ -55,8 +55,9 @@ class TestReplayJobEvents(): r.get_serializer = lambda self: mock_serializer_fn r.get_job = mocker.MagicMock(return_value=Job(id=3)) r.sleep = mocker.MagicMock() - r.get_job_events = lambda self: job_events + r.get_job_events = lambda self: (job_events, len(job_events)) r.replay_offset = lambda *args, **kwarg: 0 + r.emit_job_status = lambda job, status: True return r @mock.patch('awx.main.management.commands.replay_job_events.emit_channel_notification', lambda *a, **kw: None)