@@ -111,7 +111,7 @@ func (r *Runner) Run(ctx context.Context, id string, logs io.Writer) error {
111
111
r .cfg .DialBarrier .Done ()
112
112
r .cfg .DialBarrier .Wait ()
113
113
114
- logger .Info (ctx ,fmt . Sprintf ( "waiting for notifications" ,slog .F ("timeout" ,r .cfg .NotificationTimeout ))
114
+ logger .Info (ctx ,"waiting for notifications" ,slog .F ("timeout" ,r .cfg .NotificationTimeout ))
115
115
116
116
watchCtx ,cancel := context .WithTimeout (ctx ,r .cfg .NotificationTimeout )
117
117
defer cancel ()
@@ -192,7 +192,7 @@ func (r *Runner) watchNotifications(ctx context.Context, conn *websocket.Conn, u
192
192
193
193
// Read notifications until we have both expected types
194
194
for ! receivedCreated || ! receivedDeleted {
195
- notif ,err := r . readNotification (ctx ,conn )
195
+ notif ,err := readNotification (ctx ,conn )
196
196
if err != nil {
197
197
logger .Error (ctx ,"read notification" ,slog .Error (err ))
198
198
r .cfg .Metrics .AddError (user .Username ,"read_notification" )
@@ -224,7 +224,7 @@ func (r *Runner) watchNotifications(ctx context.Context, conn *websocket.Conn, u
224
224
return nil
225
225
}
226
226
227
- readNotification (ctx context .Context ,conn * websocket .Conn ) (codersdk .GetInboxNotificationResponse ,error ) {
227
+ func readNotification (ctx context.Context ,conn * websocket.Conn ) (codersdk.GetInboxNotificationResponse ,error ) {
228
228
_ ,message ,err := conn .Read (ctx )
229
229
if err != nil {
230
230
return codersdk.GetInboxNotificationResponse {},err