references/lobe-chat
1
0
Fork 0
mirror of https://github.com/lobehub/lobe-chat.git synced 2026-06-13 19:20:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

✨ feat(task): auto-ensure qstash schedule for task system (#14771)

Browse Source 
* ✨ feat(task): auto-ensure qstash schedule

chore: cleanup code

chore: cleanup code

chore: cleanup code

* chore: migrate qstash init workflow to startServer

chore: migrate qstash init workflow to startServer

* fix: set default QSTASH_URL to eu region, same as SDK

fix: set default QSTASH_URL to eu region, same as SDK
This commit is contained in:
Zhijie He
2026-06-05 02:07:03 +08:00
committed by GitHub
parent f5d78d3d28
commit 25635ddb38
1 changed files with 44 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/serverLauncher/startServer.js
+44
View File
@@ -163,6 +163,47 @@ const startGateway = async () => {
console.error('❌ Gateway: Failed to start after retries.');
};
// Function to create QStash schedule for dispatching workflow tasks every 10 minutes
const createQstashSchedule = async () => {
const QSTASH_URL = process.env.QSTASH_URL || 'https://qstash-eu-central-1.upstash.io';
const QSTASH_TOKEN = process.env.QSTASH_TOKEN;
if (!QSTASH_TOKEN) {
console.warn('⚠️ QStash: QSTASH_TOKEN not set. Skipping schedule creation.');
return;
}
const APP_URL = process.env.APP_URL;
if (!APP_URL) {
console.warn('⚠️ QStash: APP_URL not set. Skipping schedule creation.');
return;
}
const url = `${QSTASH_URL}/v2/schedules/${APP_URL}/api/workflows/task/schedule-dispatch`;
try {
const res = await fetch(url, {
method: 'POST',
headers: {
'Authorization': `Bearer ${QSTASH_TOKEN}`,
'Content-Type': 'application/json',
'Upstash-Method': 'POST',
'Upstash-Cron': '*/10 * * * *',
'Upstash-Schedule-Id': 'lobe-task-schedule-dispatch',
},
body: JSON.stringify({}),
});
if (res.ok) {
console.log('✅ QStash: Schedule created successfully.');
} else {
console.error(`❌ QStash: Failed to create schedule. Status ${res.status}`);
}
} catch (err) {
console.error('❌ QStash: Error creating schedule:', err);
}
};
// Main function to run the server with optional proxy
const runServer = async () => {
const PROXY_URL = process.env.PROXY_URL || ''; // Default empty string to avoid undefined errors
@@ -204,6 +245,9 @@ const runServer = async () => {
// Start gateway in background after server is ready
startGateway();
// Create QStash schedule for workflow task dispatching
createQstashSchedule();
// Run the server in either database or non-database mode
await runServer();
})();