mirror of
https://github.com/lobehub/lobehub.git
synced 2026-03-26 13:19:34 +07:00
38 lines
1.5 KiB
Diff
38 lines
1.5 KiB
Diff
diff --git a/chunk-RQPZUJXG.mjs b/chunk-RQPZUJXG.mjs
|
|
index d1a9b4a460efc59304ec30e6bc63a127f1aac6d6..4303089796e63297f79926fc9f9bd976029b1a8e 100644
|
|
--- a/chunk-RQPZUJXG.mjs
|
|
+++ b/chunk-RQPZUJXG.mjs
|
|
@@ -326,6 +326,20 @@ var HttpClient = class {
|
|
}
|
|
if (response.status < 200 || response.status >= 300) {
|
|
const body = await response.text();
|
|
+ // Debug aid: log non-2xx responses to trace publish failures (e.g., 400) with context
|
|
+ try {
|
|
+ console.error(
|
|
+ "[upstash-qstash] request failed",
|
|
+ JSON.stringify({
|
|
+ status: response.status,
|
|
+ url: response.url,
|
|
+ headers: Object.fromEntries(response.headers.entries()),
|
|
+ body
|
|
+ })
|
|
+ );
|
|
+ } catch {
|
|
+ // ignore logging failures to preserve original throw path
|
|
+ }
|
|
throw new QstashError(
|
|
body.length > 0 ? body : `Error: status=${response.status}`,
|
|
response.status
|
|
@@ -1841,8 +1855,10 @@ var AutoExecutor = class _AutoExecutor {
|
|
if (error instanceof QStashWorkflowAbort) {
|
|
throw error;
|
|
}
|
|
+
|
|
+ const errorMessage = error instanceof Error ? error.message : typeof error === "object" ? JSON.stringify(error) : String(error);
|
|
throw new QStashWorkflowError(
|
|
- `Error submitting steps to QStash in partial parallel step execution: ${error}`
|
|
+ `Error submitting steps to QStash in partial parallel step execution: ${errorMessage}`
|
|
);
|
|
}
|
|
break;
|