jerry.tian/fal-js
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: send logs query param to status request as true by default

Browse Source
This commit is contained in:
Matteo Ferrando 2023-10-24 11:18:21 -04:00
parent 0e3cb85939
commit d7e9dd1515
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
libs/client/src/function.ts
View File

@ -131,7 +131,7 @@ export async function subscribe<Input, Output>(
const pollInterval = options.pollInterval ?? 1000; const pollInterval = options.pollInterval ?? 1000;
const poll = async () => { const poll = async () => {
try { try {
const requestStatus = await queue.status(id, requestId); const requestStatus = await queue.status(id, requestId, true);
if (options.onQueueUpdate) { if (options.onQueueUpdate) {
options.onQueueUpdate(requestStatus); options.onQueueUpdate(requestStatus);
} }
@ -197,9 +197,10 @@ interface Queue {
* *
* @param id - The ID or URL of the function web endpoint. * @param id - The ID or URL of the function web endpoint.
* @param requestId - The unique identifier for the enqueued request. * @param requestId - The unique identifier for the enqueued request.
* @param logs - If `true`, the response will include the logs for the request.
* @returns A promise that resolves to the status of the request. * @returns A promise that resolves to the status of the request.
*/ */
status(id: string, requestId: string): Promise<QueueStatus>; status(id: string, requestId: string, logs: boolean): Promise<QueueStatus>;
/** /**
* Retrieves the result of a specific request from the queue. * Retrieves the result of a specific request from the queue.
@ -231,10 +232,10 @@ export const queue: Queue = {
): Promise<EnqueueResult> { ): Promise<EnqueueResult> {
return run(id, { ...options, method: 'post', path: '/fal/queue/submit/' }); return run(id, { ...options, method: 'post', path: '/fal/queue/submit/' });
}, },
async status(id: string, requestId: string): Promise<QueueStatus> { async status(id: string, requestId: string, logs: boolean = true): Promise<QueueStatus> {
return run(id, { return run(id, {
method: 'get', method: 'get',
path: `/fal/queue/requests/${requestId}/status`, path: `/fal/queue/requests/${requestId}/status?logs=${logs ? '1' : '0'}`,
}); });
}, },
async result<Output>(id: string, requestId: string): Promise<Output> { async result<Output>(id: string, requestId: string): Promise<Output> {