File tree Expand file tree Collapse file tree 5 files changed +3
-325
lines changed
app/api/workflows/[id]/execute Expand file tree Collapse file tree 5 files changed +3
-325
lines changed Original file line number Diff line number Diff line change @@ -329,7 +329,8 @@ async function enqueueDirectWorkflowExecution(
329329 * Supports both SSE streaming (for interactive/manual runs) and direct JSON responses (for background jobs).
330330 */
331331export async function POST(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
332- if (!hasExternalApiCredentials(req.headers)) {
332+ const isSessionRequest = req.headers.has('cookie') && !hasExternalApiCredentials(req.headers)
333+ if (isSessionRequest) {
333334 return handleExecutePost(req, params)
334335 }
335336
Original file line number Diff line number Diff line change 11export { BullMQJobQueue } from './bullmq'
22export { DatabaseJobQueue } from './database'
3- export { RedisJobQueue } from './redis'
43export { TriggerDevJobQueue } from './trigger-dev'
Load Diff This file was deleted.
Load Diff This file was deleted.
Original file line number Diff line number Diff line change @@ -99,4 +99,4 @@ export interface JobQueueBackend {
9999 markJobFailed(jobId: string, error: string): Promise<void>
100100}
101101
102- export type AsyncBackendType = 'trigger-dev' | 'bullmq' | 'redis' | ' database'
102+ export type AsyncBackendType = 'trigger-dev' | 'bullmq' | 'database'
You can’t perform that action at this time.
0 commit comments