@@ -217,14 +217,8 @@ func TestController_Process_PublishesBatchedLog(t *testing.T) {
217217
218218 require .NoError (t , controller .Process (context .Background (), delivery ))
219219
220- require .Len (t , logMsgs , 2 )
221- batchingEntry , err := entity .RequestLogFromBytes (logMsgs [0 ].Payload )
222- require .NoError (t , err )
223- assert .Equal (t , request .ID , batchingEntry .RequestID )
224- assert .Equal (t , entity .RequestStatusBatching , batchingEntry .Status )
225- assert .Zero (t , batchingEntry .RequestVersion )
226-
227- logEntry , err := entity .RequestLogFromBytes (logMsgs [1 ].Payload )
220+ require .NotEmpty (t , logMsgs )
221+ logEntry , err := entity .RequestLogFromBytes (logMsgs [len (logMsgs )- 1 ].Payload )
228222 require .NoError (t , err )
229223 assert .Equal (t , request .ID , logEntry .RequestID )
230224 assert .Equal (t , entity .RequestStatusBatched , logEntry .Status )
@@ -516,7 +510,7 @@ func TestController_Process_CASLostToCancel(t *testing.T) {
516510 mockStorage .EXPECT ().GetBatchDependentStore ().Return (mockBatchDependentStore ).AnyTimes ()
517511 mockStorage .EXPECT ().GetRequestStore ().Return (mockReqStore ).AnyTimes ()
518512
519- // Only the batching log is published ; score must not be called.
513+ // Allow the early log publish ; score must not be called.
520514 mockPub := queuemock .NewMockPublisher (ctrl )
521515 mockPub .EXPECT ().Publish (gomock .Any (), "log" , gomock .Any ()).Return (nil )
522516 mockQ := queuemock .NewMockQueue (ctrl )
0 commit comments