Skip to content

Commit 971e367

Browse files
authored
chore: improve logging in provisionerd_test (#5353)
1 parent cd04330 commit 971e367

File tree

1 file changed

+22
-17
lines changed

1 file changed

+22
-17
lines changed

provisionerd/provisionerd_test.go

Lines changed: 22 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -324,11 +324,12 @@ func TestProvisionerd(t *testing.T) {
324324
},
325325
}),
326326
})
327+
327328
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())
331329
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")
332333
})
333334

334335
t.Run("TemplateDryRun", func(t *testing.T) {
@@ -378,8 +379,14 @@ func TestProvisionerd(t *testing.T) {
378379
}, nil
379380
},
380381
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)
383390
}
384391
return &proto.UpdateJobResponse{}, nil
385392
},
@@ -405,9 +412,9 @@ func TestProvisionerd(t *testing.T) {
405412
})
406413

407414
require.Condition(t, closedWithin(completeChan, testutil.WaitShort))
408-
require.True(t, didLog.Load())
409-
require.True(t, didComplete.Load())
410415
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")
411418
})
412419

413420
t.Run("WorkspaceBuild", func(t *testing.T) {
@@ -476,9 +483,9 @@ func TestProvisionerd(t *testing.T) {
476483
}),
477484
})
478485
require.Condition(t, closedWithin(completeChan, testutil.WaitShort))
479-
require.True(t, didLog.Load())
480-
require.True(t, didComplete.Load())
481486
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")
482489
})
483490

484491
t.Run("WorkspaceBuildQuotaExceeded", func(t *testing.T) {
@@ -566,10 +573,10 @@ func TestProvisionerd(t *testing.T) {
566573
}),
567574
})
568575
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())
572576
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")
573580
})
574581

575582
t.Run("WorkspaceBuildFailComplete", func(t *testing.T) {
@@ -622,8 +629,8 @@ func TestProvisionerd(t *testing.T) {
622629
}),
623630
})
624631
require.Condition(t, closedWithin(completeChan, testutil.WaitShort))
625-
require.True(t, didFail.Load())
626632
require.NoError(t, closer.Close())
633+
assert.True(t, didFail.Load(), "should fail the job")
627634
})
628635

629636
t.Run("Shutdown", func(t *testing.T) {
@@ -1022,11 +1029,9 @@ func TestProvisionerd(t *testing.T) {
10221029
}),
10231030
})
10241031
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 | ")
10291032
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 | ")
10301035
})
10311036
}
10321037

0 commit comments

Comments
 (0)