Skip to content

Commit 43d63f9

Browse files
committed
MC-25132 Fix deadlocks related to crons / consumers
1 parent 49d53ce commit 43d63f9

File tree

1 file changed

+20
-5
lines changed

1 file changed

+20
-5
lines changed

app/code/Magento/Cron/Test/Unit/Observer/ProcessCronQueueObserverTest.php

Lines changed: 20 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -963,11 +963,26 @@ public function testMissedJobsCleanedInTime()
963963
$connectionMock->expects($this->exactly(5))
964964
->method('delete')
965965
->withConsecutive(
966-
[$tableName, ['status = ?' => 'pending', 'job_code in (?)' => ['test_job1']]],
967-
[$tableName, ['status = ?' => 'success', 'job_code in (?)' => ['test_job1'], 'scheduled_at < ?' => null]],
968-
[$tableName, ['status = ?' => 'missed', 'job_code in (?)' => ['test_job1'], 'scheduled_at < ?' => null]],
969-
[$tableName, ['status = ?' => 'error', 'job_code in (?)' => ['test_job1'], 'scheduled_at < ?' => null]],
970-
[$tableName, ['status = ?' => 'pending', 'job_code in (?)' => ['test_job1'], 'scheduled_at < ?' => null]]
966+
[
967+
$tableName,
968+
['status = ?' => 'pending', 'job_code in (?)' => ['test_job1']]
969+
],
970+
[
971+
$tableName,
972+
['status = ?' => 'success', 'job_code in (?)' => ['test_job1'], 'scheduled_at < ?' => null]
973+
],
974+
[
975+
$tableName,
976+
['status = ?' => 'missed', 'job_code in (?)' => ['test_job1'], 'scheduled_at < ?' => null]
977+
],
978+
[
979+
$tableName,
980+
['status = ?' => 'error', 'job_code in (?)' => ['test_job1'], 'scheduled_at < ?' => null]
981+
],
982+
[
983+
$tableName,
984+
['status = ?' => 'pending', 'job_code in (?)' => ['test_job1'], 'scheduled_at < ?' => null]
985+
]
971986
)
972987
->willReturn(1);
973988

0 commit comments

Comments
 (0)