retry

package-lock.json

@@ -9,7 +9,9 @@
       "version": "0.0.0",
       "dependencies": {
         "@imgly/background-removal": "^1.7.0",
-        "dexie": "^4.0.11"
+        "dexie": "^4.0.11",
+        "p-retry": "^6.2.1",
+        "p-timeout": "^6.1.4"
       },
       "devDependencies": {
         "@sveltejs/vite-plugin-svelte": "^5.0.3",
@@ -1168,6 +1170,12 @@
         "undici-types": "~7.8.0"
       }
     },
+    "node_modules/@types/retry": {
+      "version": "0.12.2",
+      "resolved": "https://registry.npmjs.org/@types/retry/-/retry-0.12.2.tgz",
+      "integrity": "sha512-XISRgDJ2Tc5q4TRqvgJtzsRkFYNJzZrhTdtMoGVBttwzzQJkPnS3WWTFc7kuDRoPtPakl+T+OfdEUjYJj7Jbow==",
+      "license": "MIT"
+    },
     "node_modules/@types/statuses": {
       "version": "2.0.6",
       "resolved": "https://registry.npmjs.org/@types/statuses/-/statuses-2.0.6.tgz",
@@ -1892,6 +1900,18 @@
         "node": ">=8"
       }
     },
+    "node_modules/is-network-error": {
+      "version": "1.1.0",
+      "resolved": "https://registry.npmjs.org/is-network-error/-/is-network-error-1.1.0.tgz",
+      "integrity": "sha512-tUdRRAnhT+OtCZR/LxZelH/C7QtjtFrTu5tXCA8pl55eTUElUHT+GPYV8MBMBvea/j+NxQqVt3LbWMRir7Gx9g==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=16"
+      },
+      "funding": {
+        "url": "https://github.com/sponsors/sindresorhus"
+      }
+    },
     "node_modules/is-node-process": {
       "version": "1.2.0",
       "resolved": "https://registry.npmjs.org/is-node-process/-/is-node-process-1.2.0.tgz",
@@ -2111,6 +2131,35 @@
       "optional": true,
       "peer": true
     },
+    "node_modules/p-retry": {
+      "version": "6.2.1",
+      "resolved": "https://registry.npmjs.org/p-retry/-/p-retry-6.2.1.tgz",
+      "integrity": "sha512-hEt02O4hUct5wtwg4H4KcWgDdm+l1bOaEy/hWzd8xtXB9BqxTWBBhb+2ImAtH4Cv4rPjV76xN3Zumqk3k3AhhQ==",
+      "license": "MIT",
+      "dependencies": {
+        "@types/retry": "0.12.2",
+        "is-network-error": "^1.0.0",
+        "retry": "^0.13.1"
+      },
+      "engines": {
+        "node": ">=16.17"
+      },
+      "funding": {
+        "url": "https://github.com/sponsors/sindresorhus"
+      }
+    },
+    "node_modules/p-timeout": {
+      "version": "6.1.4",
+      "resolved": "https://registry.npmjs.org/p-timeout/-/p-timeout-6.1.4.tgz",
+      "integrity": "sha512-MyIV3ZA/PmyBN/ud8vV9XzwTrNtR4jFrObymZYnZqMmW0zA8Z17vnT0rBgFE/TlohB+YCHqXMgZzb3Csp49vqg==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=14.16"
+      },
+      "funding": {
+        "url": "https://github.com/sponsors/sindresorhus"
+      }
+    },
     "node_modules/path-to-regexp": {
       "version": "6.3.0",
       "resolved": "https://registry.npmjs.org/path-to-regexp/-/path-to-regexp-6.3.0.tgz",
@@ -2289,6 +2338,15 @@
       "optional": true,
       "peer": true
     },
+    "node_modules/retry": {
+      "version": "0.13.1",
+      "resolved": "https://registry.npmjs.org/retry/-/retry-0.13.1.tgz",
+      "integrity": "sha512-XQBQ3I8W1Cge0Seh+6gjj03LbmRFWuoszgK9ooCpwYIrhhoO80pfq4cUkU5DkknwfOfFteRwlZ56PYOGYyFWdg==",
+      "license": "MIT",
+      "engines": {
+        "node": ">= 4"
+      }
+    },
     "node_modules/rollup": {
       "version": "4.45.1",
       "resolved": "https://registry.npmjs.org/rollup/-/rollup-4.45.1.tgz",

package.json

@@ -26,6 +26,8 @@
   },
   "dependencies": {
     "@imgly/background-removal": "^1.7.0",
-    "dexie": "^4.0.11"
+    "dexie": "^4.0.11",
+    "p-retry": "^6.2.1",
+    "p-timeout": "^6.1.4"
   }
 }

src/lib/components/PicletGenerator/PicletGenerator.svelte

@@ -10,6 +10,7 @@
   import { savePicletInstance, generatedDataToPicletInstance } from '$lib/db/piclets';
   import { PicletType, TYPE_DATA } from '$lib/types/picletTypes';
   import { EncounterService } from '$lib/db/encounterService';
+  import { withQwenTimeout } from '$lib/utils/qwenTimeout';
   
   interface Props extends PicletGeneratorProps {
     // Trainer mode props
@@ -311,12 +312,12 @@ Format your response exactly as follows:
       console.log('Generating monster concept with qwen3...');
       
       // Call the add_message function (fn_index 13)
-      const output = await qwenClient.predict(13, [
+      const output = await withQwenTimeout(() => qwenClient.predict(13, [
         conceptPrompt,          // input_value
         defaultSettings,        // settings_form_value  
         thinkingBtnState,       // thinking_btn_state_value
         defaultState            // state_value
-      ]);
+      ]));
       
       console.log('Qwen3 concept response:', output);
       
@@ -408,12 +409,12 @@ Create a concise visual description (1-3 sentences, max 100 words). Focus only o
       console.log('Generating image prompt with qwen3...');
       
       // Call the add_message function (fn_index 13)
-      const output = await qwenClient.predict(13, [
+      const output = await withQwenTimeout(() => qwenClient.predict(13, [
         imagePromptPrompt,      // input_value
         defaultSettings,        // settings_form_value  
         thinkingBtnState,       // thinking_btn_state_value
         defaultState            // state_value
-      ]);
+      ]));
       
       console.log('Qwen3 image prompt response:', output);
       
@@ -770,12 +771,12 @@ Write your response within \`\`\`json\`\`\``;
       };
       
       // Call the add_message function (fn_index 13)
-      const output = await qwenClient.predict(13, [
+      const output = await withQwenTimeout(() => qwenClient.predict(13, [
         statsPrompt,            // input_value
         defaultSettings,        // settings_form_value  
         thinkingBtnState,       // thinking_btn_state_value
         defaultState            // state_value
-      ]);
+      ]));
       
       console.log('Qwen3 stats response:', output);
       

src/lib/utils/qwenTimeout.ts

@@ -0,0 +1,20 @@
+import pRetry, { AbortError } from 'p-retry';
+import pTimeout from 'p-timeout';
+
+export async function withQwenTimeout<T>(
+  fn: () => Promise<T>,
+  { totalTimeout = 180_000, retries = 2 } = {}
+): Promise<T> {
+  return pRetry(
+    () => pTimeout(fn(), { milliseconds: totalTimeout }),
+    {
+      retries,
+      onFailedAttempt: (error) => {
+        console.error(`qwen3 attempt #${error.attemptNumber} failed: ${error.message}`);
+        if (error.retriesLeft === 0) {
+          console.error('qwen3 max retries reached, giving up');
+        }
+      }
+    }
+  );
+}