File tree Expand file tree Collapse file tree 1 file changed +4
-16
lines changed
Expand file tree Collapse file tree 1 file changed +4
-16
lines changed Original file line number Diff line number Diff line change 2222});
2323
2424it ('records job start with all parameters ' , function () {
25- $ this ->queueRepository ->shouldReceive ('markQueueDiscovered ' )
26- ->once ()
27- ->with ('redis ' , 'default ' );
28-
25+ // Queue discovery now happens atomically inside recordStart()
2926 $ this ->repository ->shouldReceive ('recordStart ' )
3027 ->once ()
3128 ->with (
5855})->group ('functional ' );
5956
6057it ('handles different queue connections ' , function () {
61- $ this ->queueRepository ->shouldReceive ('markQueueDiscovered ' )
62- ->once ()
63- ->with ('database ' , 'emails ' );
64-
58+ // Queue discovery now happens atomically inside recordStart()
6559 $ this ->repository ->shouldReceive ('recordStart ' )
6660 ->once ()
6761 ->with (
8377it ('records start time at execution moment ' , function () {
8478 Carbon::setTestNow ('2024-01-15 14:45:30 ' );
8579
86- $ this ->queueRepository ->shouldReceive ('markQueueDiscovered ' )
87- ->once ()
88- ->with ('redis ' , 'reports ' );
89-
80+ // Queue discovery now happens atomically inside recordStart()
9081 $ this ->repository ->shouldReceive ('recordStart ' )
9182 ->once ()
9283 ->with (
10697})->group ('functional ' );
10798
10899it ('handles job IDs with special characters ' , function () {
109- $ this ->queueRepository ->shouldReceive ('markQueueDiscovered ' )
110- ->once ()
111- ->with ('redis ' , 'default ' );
112-
100+ // Queue discovery now happens atomically inside recordStart()
113101 $ this ->repository ->shouldReceive ('recordStart ' )
114102 ->once ()
115103 ->with (
You can’t perform that action at this time.
0 commit comments