(ctx context.Context, id string, logs io.Writer)
| 179 | } |
| 180 | |
| 181 | func (r *Runner) Cleanup(ctx context.Context, id string, logs io.Writer) error { |
| 182 | if r.createUserRunner != nil { |
| 183 | _, _ = fmt.Fprintln(logs, "Cleaning up user...") |
| 184 | if err := r.createUserRunner.Cleanup(ctx, id, logs); err != nil { |
| 185 | return xerrors.Errorf("cleanup user: %w", err) |
| 186 | } |
| 187 | } |
| 188 | |
| 189 | return nil |
| 190 | } |
| 191 | |
| 192 | const ( |
| 193 | WebsocketNotificationReceiptTimeMetric = "notification_websocket_receipt_time" |