| 1176 | } |
| 1177 | |
| 1178 | func (r *Runner) flushQueuedLogs(ctx context.Context) { |
| 1179 | r.mutex.Lock() |
| 1180 | if r.flushLogsTimer != nil { |
| 1181 | r.flushLogsTimer.Stop() |
| 1182 | } |
| 1183 | logs := r.queuedLogs |
| 1184 | r.queuedLogs = make([]*proto.Log, 0) |
| 1185 | r.mutex.Unlock() |
| 1186 | _, err := r.update(ctx, &proto.UpdateJobRequest{ |
| 1187 | JobId: r.job.JobId, |
| 1188 | Logs: logs, |
| 1189 | }) |
| 1190 | if err != nil { |
| 1191 | if errors.Is(err, errUpdateSkipped) { |
| 1192 | return |
| 1193 | } |
| 1194 | r.logger.Error(ctx, "flush queued logs", slog.Error(err)) |
| 1195 | } |
| 1196 | } |
| 1197 | |
| 1198 | func redactVariableValues(variableValues []*sdkproto.VariableValue) []*sdkproto.VariableValue { |
| 1199 | var redacted []*sdkproto.VariableValue |