diff --git a/internal/manager/job_deleter/job_deleter.go b/internal/manager/job_deleter/job_deleter.go index 5e65bc79..f85db04f 100644 --- a/internal/manager/job_deleter/job_deleter.go +++ b/internal/manager/job_deleter/job_deleter.go @@ -231,10 +231,6 @@ func (s *Service) deleteJob(ctx context.Context, jobUUID string) error { Stringer("duration", duration). Msg("job deleter: job removal complete") - // Request a consistency check on the database. In the past there have been - // some issues after deleting a job. - s.persist.RequestIntegrityCheck() - return nil } diff --git a/internal/manager/job_deleter/job_deleter_test.go b/internal/manager/job_deleter/job_deleter_test.go index 6b347196..84c6a64b 100644 --- a/internal/manager/job_deleter/job_deleter_test.go +++ b/internal/manager/job_deleter/job_deleter_test.go @@ -110,7 +110,6 @@ func TestDeleteJobWithoutShaman(t *testing.T) { // Mock that everything went OK. mocks.storage.EXPECT().RemoveJobStorage(mocks.ctx, jobUUID) mocks.persist.EXPECT().DeleteJob(mocks.ctx, jobUUID) - mocks.persist.EXPECT().RequestIntegrityCheck() mocks.broadcaster.EXPECT().BroadcastJobUpdate(gomock.Any()) require.NoError(t, s.deleteJob(mocks.ctx, jobUUID)) } @@ -155,7 +154,6 @@ func TestDeleteJobWithShaman(t *testing.T) { mocks.shaman.EXPECT().EraseCheckout(shamanCheckoutID) mocks.storage.EXPECT().RemoveJobStorage(mocks.ctx, jobUUID) mocks.persist.EXPECT().DeleteJob(mocks.ctx, jobUUID) - mocks.persist.EXPECT().RequestIntegrityCheck() mocks.broadcaster.EXPECT().BroadcastJobUpdate(gomock.Any()) require.NoError(t, s.deleteJob(mocks.ctx, jobUUID)) }