flowControl period parameter does not work with publishJSON

[Pankkss]

Problem

When using the period parameter in the publishJSON function, I get the following error:

Error processing webhook: Error [QstashError]: {"error":"Upstash-Flow-Control-Value should be either rate=X or parallelism=Y, or both as comma-separated values"}
    at async queueSingleEvent (lib/queue/qstash.ts:74:25)
    at async POST (app/api/public/webhooks/stripe/route.ts:45:16)
  72 |         }
  73 |         console.log('params', params);
> 74 |         const response = await getClient().publishJSON({
     |                         ^
  75 |             url: `${process.env.NEXT_PUBLIC_APP_URL}/api/public/webhooks/${url}`,
  76 |             headers: {
  77 |                 ...headers, {
  status: 400
}

The code block below works as long as I don't include the period parameter. I've tried the period parameter with both a number and string like "1s". Neither works.

Code block

        const response = await getClient().publishJSON({
            url: `${process.env.NEXT_PUBLIC_APP_URL}/api/public/webhooks/${url}`,
            headers: {
                ...headers,
            },
            messageId: message_id,
            flowControl: {
                key: QUEUE_TWILIO,
                rate: isDev() ? 1 : 3,
                parallelism: 3,
                period: "1s",
            },
            notBefore: isDev() ? 0 : Math.floor(delivery_date!.getTime() / 1000),
            body: {
                event: event,
                message_id: message_id,
                isDev: isDev(),
            }
        });

I assume this implementation should work as it's structure is similar to (these docs)[https://upstash.com/docs/qstash/features/flowcontrol], specifically this example:

const client = new Client({ token: "<QSTASH_TOKEN>" });

await client.publishJSON({
    url: "https://example.com",
    body: { hello: "world" },
    flowControl: { key: "USER_GIVEN_KEY", rate: 10, parallelism: 20, period: "1m" },
});

[CahidArda]

Hi @Pankkss,

Sorry for the late response. I have tested the code you shared and didn't get the error you got. Can you make sure that you are on the latest qstash version and try again?