@@ -324,11 +324,12 @@ func TestProvisionerd(t *testing.T) {
324
324
},
325
325
}),
326
326
})
327
+
327
328
require .Condition (t , closedWithin (completeChan , testutil .WaitShort ))
328
- require .True (t , didLog .Load ())
329
- require .True (t , didComplete .Load ())
330
- require .True (t , didDryRun .Load ())
331
329
require .NoError (t , closer .Close ())
330
+ assert .True (t , didLog .Load (), "should log some updates" )
331
+ assert .True (t , didComplete .Load (), "should complete the job" )
332
+ assert .True (t , didDryRun .Load (), "should be a dry run" )
332
333
})
333
334
334
335
t .Run ("TemplateDryRun" , func (t * testing.T ) {
@@ -378,8 +379,14 @@ func TestProvisionerd(t *testing.T) {
378
379
}, nil
379
380
},
380
381
updateJob : func (ctx context.Context , update * proto.UpdateJobRequest ) (* proto.UpdateJobResponse , error ) {
381
- if len (update .Logs ) != 0 {
382
- didLog .Store (true )
382
+ if len (update .Logs ) == 0 {
383
+ t .Log ("provisionerDaemonTestServer: no log messages" )
384
+ return & proto.UpdateJobResponse {}, nil
385
+ }
386
+
387
+ didLog .Store (true )
388
+ for _ , msg := range update .Logs {
389
+ t .Log ("provisionerDaemonTestServer" , "msg:" , msg )
383
390
}
384
391
return & proto.UpdateJobResponse {}, nil
385
392
},
@@ -405,9 +412,9 @@ func TestProvisionerd(t *testing.T) {
405
412
})
406
413
407
414
require .Condition (t , closedWithin (completeChan , testutil .WaitShort ))
408
- require .True (t , didLog .Load ())
409
- require .True (t , didComplete .Load ())
410
415
require .NoError (t , closer .Close ())
416
+ assert .True (t , didLog .Load (), "should log some updates" )
417
+ assert .True (t , didComplete .Load (), "should complete the job" )
411
418
})
412
419
413
420
t .Run ("WorkspaceBuild" , func (t * testing.T ) {
@@ -476,9 +483,9 @@ func TestProvisionerd(t *testing.T) {
476
483
}),
477
484
})
478
485
require .Condition (t , closedWithin (completeChan , testutil .WaitShort ))
479
- require .True (t , didLog .Load ())
480
- require .True (t , didComplete .Load ())
481
486
require .NoError (t , closer .Close ())
487
+ assert .True (t , didLog .Load (), "should log some updates" )
488
+ assert .True (t , didComplete .Load (), "should complete the job" )
482
489
})
483
490
484
491
t .Run ("WorkspaceBuildQuotaExceeded" , func (t * testing.T ) {
@@ -566,10 +573,10 @@ func TestProvisionerd(t *testing.T) {
566
573
}),
567
574
})
568
575
require .Condition (t , closedWithin (completeChan , testutil .WaitShort ))
569
- require .True (t , didLog .Load ())
570
- require .True (t , didFail .Load ())
571
- require .False (t , didComplete .Load ())
572
576
require .NoError (t , closer .Close ())
577
+ assert .True (t , didLog .Load (), "should log some updates" )
578
+ assert .False (t , didComplete .Load (), "should complete the job" )
579
+ assert .True (t , didFail .Load (), "should fail the job" )
573
580
})
574
581
575
582
t .Run ("WorkspaceBuildFailComplete" , func (t * testing.T ) {
@@ -622,8 +629,8 @@ func TestProvisionerd(t *testing.T) {
622
629
}),
623
630
})
624
631
require .Condition (t , closedWithin (completeChan , testutil .WaitShort ))
625
- require .True (t , didFail .Load ())
626
632
require .NoError (t , closer .Close ())
633
+ assert .True (t , didFail .Load (), "should fail the job" )
627
634
})
628
635
629
636
t .Run ("Shutdown" , func (t * testing.T ) {
@@ -1022,11 +1029,9 @@ func TestProvisionerd(t *testing.T) {
1022
1029
}),
1023
1030
})
1024
1031
require .Condition (t , closedWithin (completeChan , testutil .WaitShort ))
1025
- m .Lock ()
1026
- defer m .Unlock ()
1027
- require .Equal (t , ops [len (ops )- 1 ], "CompleteJob" )
1028
- require .Contains (t , ops [0 :len (ops )- 1 ], "Log: Cleaning Up | " )
1029
1032
require .NoError (t , server .Close ())
1033
+ assert .Equal (t , ops [len (ops )- 1 ], "CompleteJob" )
1034
+ assert .Contains (t , ops [0 :len (ops )- 1 ], "Log: Cleaning Up | " )
1030
1035
})
1031
1036
}
1032
1037
0 commit comments