abbyswag/qwen-code
1
0
Fork 0
mirror of https://github.com/QwenLM/qwen-code.git synced 2025-12-19 09:33:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: print request errors for logging only in debug mode (#1006)

Browse Source
This commit is contained in:
tanzhenxin
2025-11-12 19:46:28 +08:00
committed by GitHub
parent 06141cda8d
commit d5d96c726a
1 changed files with 4 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
packages/core/src/telemetry/qwen-logger/qwen-logger.ts
View File

@@ -48,7 +48,6 @@ import type {
} from './event-types.js'; } from './event-types.js';
import type { Config } from '../../config/config.js'; import type { Config } from '../../config/config.js';
import { safeJsonStringify } from '../../utils/safeJsonStringify.js'; import { safeJsonStringify } from '../../utils/safeJsonStringify.js';
import { type HttpError, retryWithBackoff } from '../../utils/retry.js';
import { InstallationManager } from '../../utils/installationManager.js'; import { InstallationManager } from '../../utils/installationManager.js';
import { FixedDeque } from 'mnemonist'; import { FixedDeque } from 'mnemonist';
import { AuthType } from '../../core/contentGenerator.js'; import { AuthType } from '../../core/contentGenerator.js';
@@ -288,8 +287,8 @@ export class QwenLogger {
const rumPayload = await this.createRumPayload(); const rumPayload = await this.createRumPayload();
// Override events with the ones we're sending // Override events with the ones we're sending
rumPayload.events = eventsToSend; rumPayload.events = eventsToSend;
const flushFn = () => try {
new Promise<Buffer>((resolve, reject) => { await new Promise<Buffer>((resolve, reject) => {
const body = safeJsonStringify(rumPayload); const body = safeJsonStringify(rumPayload);
const options = { const options = {
hostname: USAGE_STATS_HOSTNAME, hostname: USAGE_STATS_HOSTNAME,
@@ -311,10 +310,9 @@ export class QwenLogger {
res.statusCode && res.statusCode &&
(res.statusCode < 200 || res.statusCode >= 300) (res.statusCode < 200 || res.statusCode >= 300)
) { ) {
const err: HttpError = new Error( const err = new Error(
`Request failed with status ${res.statusCode}`, `Request failed with status ${res.statusCode}`,
); );
err.status = res.statusCode;
res.resume(); res.resume();
return reject(err); return reject(err);
} }
@@ -326,26 +324,11 @@ export class QwenLogger {
req.end(body); req.end(body);
}); });
try {
await retryWithBackoff(flushFn, {
maxAttempts: 3,
initialDelayMs: 200,
shouldRetryOnError: (err: unknown) => {
if (!(err instanceof Error)) return false;
const status = (err as HttpError).status as number | undefined;
// If status is not available, it's likely a network error
if (status === undefined) return true;
// Retry on 429 (Too many Requests) and 5xx server errors.
return status === 429 || (status >= 500 && status < 600);
},
});
this.lastFlushTime = Date.now(); this.lastFlushTime = Date.now();
return {}; return {};
} catch (error) { } catch (error) {
if (this.config?.getDebugMode()) { if (this.config?.getDebugMode()) {
console.error('RUM flush failed after multiple retries.', error); console.error('RUM flush failed.', error);
} }
// Re-queue failed events for retry // Re-queue failed events for retry