Skip to content

Commit f722ed3

Browse files
committed
feat(sdk,core): drop the combined concurrency override client methods
The combined override and reset never ship; runtime management of the new named limits arrives with its own management API.
1 parent 0177e21 commit f722ed3

2 files changed

Lines changed: 0 additions & 120 deletions

File tree

‎packages/core/src/v3/apiClient/index.ts‎

Lines changed: 0 additions & 45 deletions
Original file line numberDiff line numberDiff line change
@@ -1765,51 +1765,6 @@ export class ApiClient {
17651765
);
17661766
}
17671767

1768-
overrideQueueCombinedConcurrencyLimit(
1769-
queue: RetrieveQueueParam,
1770-
concurrencyLimit: number,
1771-
requestOptions?: ZodFetchOptions
1772-
) {
1773-
const type = typeof queue === "string" ? "id" : queue.type;
1774-
const value = typeof queue === "string" ? queue : queue.name;
1775-
1776-
const encodedValue = encodeURIComponent(value.replace(/\//g, "%2F"));
1777-
1778-
return zodfetch(
1779-
QueueItem,
1780-
`${this.baseUrl}/api/v1/queues/${encodedValue}/concurrency/combined/override`,
1781-
{
1782-
method: "POST",
1783-
headers: this.#getHeaders(false),
1784-
body: JSON.stringify({
1785-
type,
1786-
concurrencyLimit,
1787-
}),
1788-
},
1789-
mergeRequestOptions(this.defaultRequestOptions, requestOptions)
1790-
);
1791-
}
1792-
1793-
resetQueueCombinedConcurrencyLimit(queue: RetrieveQueueParam, requestOptions?: ZodFetchOptions) {
1794-
const type = typeof queue === "string" ? "id" : queue.type;
1795-
const value = typeof queue === "string" ? queue : queue.name;
1796-
1797-
const encodedValue = encodeURIComponent(value.replace(/\//g, "%2F"));
1798-
1799-
return zodfetch(
1800-
QueueItem,
1801-
`${this.baseUrl}/api/v1/queues/${encodedValue}/concurrency/combined/reset`,
1802-
{
1803-
method: "POST",
1804-
headers: this.#getHeaders(false),
1805-
body: JSON.stringify({
1806-
type,
1807-
}),
1808-
},
1809-
mergeRequestOptions(this.defaultRequestOptions, requestOptions)
1810-
);
1811-
}
1812-
18131768
subscribeToRun<TRunTypes extends AnyRunTypes>(
18141769
runId: string,
18151770
options?: {

‎packages/trigger-sdk/src/v3/queues.ts‎

Lines changed: 0 additions & 75 deletions
Original file line numberDiff line numberDiff line change
@@ -172,81 +172,6 @@ export function overrideConcurrencyLimit(
172172
return apiClient.overrideQueueConcurrencyLimit(queue, concurrencyLimit, $requestOptions);
173173
}
174174

175-
/**
176-
* Overrides the combined concurrency limit of a queue: the cap on concurrent runs across
177-
* all of its `concurrencyKey` values.
178-
*
179-
* @param queue - The ID of the queue, or the type and name
180-
* @param concurrencyLimit - The combined concurrency limit to apply
181-
* @returns The updated queue state
182-
*/
183-
export function overrideCombinedConcurrencyLimit(
184-
queue: RetrieveQueueParam,
185-
concurrencyLimit: number,
186-
requestOptions?: ApiRequestOptions
187-
): ApiPromise<QueueItem> {
188-
const apiClient = apiClientManager.clientOrThrow();
189-
190-
const $requestOptions = mergeRequestOptions(
191-
{
192-
tracer,
193-
name: "queues.overrideCombinedConcurrencyLimit()",
194-
icon: "queue",
195-
attributes: {
196-
...flattenAttributes({ queue }),
197-
...accessoryAttributes({
198-
items: [
199-
{
200-
text: typeof queue === "string" ? queue : queue.name,
201-
variant: "normal",
202-
},
203-
],
204-
style: "codepath",
205-
}),
206-
},
207-
},
208-
requestOptions
209-
);
210-
211-
return apiClient.overrideQueueCombinedConcurrencyLimit(queue, concurrencyLimit, $requestOptions);
212-
}
213-
214-
/**
215-
* Resets the combined concurrency limit of a queue back to its declared value.
216-
*
217-
* @param queue - The ID of the queue, or the type and name
218-
* @returns The updated queue state
219-
*/
220-
export function resetCombinedConcurrencyLimit(
221-
queue: RetrieveQueueParam,
222-
requestOptions?: ApiRequestOptions
223-
): ApiPromise<QueueItem> {
224-
const apiClient = apiClientManager.clientOrThrow();
225-
226-
const $requestOptions = mergeRequestOptions(
227-
{
228-
tracer,
229-
name: "queues.resetCombinedConcurrencyLimit()",
230-
icon: "queue",
231-
attributes: {
232-
...flattenAttributes({ queue }),
233-
...accessoryAttributes({
234-
items: [
235-
{
236-
text: typeof queue === "string" ? queue : queue.name,
237-
variant: "normal",
238-
},
239-
],
240-
style: "codepath",
241-
}),
242-
},
243-
},
244-
requestOptions
245-
);
246-
247-
return apiClient.resetQueueCombinedConcurrencyLimit(queue, $requestOptions);
248-
}
249-
250175
/**
251176
* Resets the concurrency limit of a queue to the base value.
252177
*

0 commit comments

Comments
 (0)