Skip to content

Commit f6be456

Browse files
committed
fix: remove entire queue rate limit
1 parent e9aa7dc commit f6be456

File tree

4 files changed

+1
-19
lines changed

4 files changed

+1
-19
lines changed

packages/backend/src/apps/tiles/__tests__/queue.test.ts

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -24,10 +24,6 @@ describe('Queue config', () => {
2424
vi.restoreAllMocks()
2525
})
2626

27-
it('configures a delayable queue', () => {
28-
expect(tilesApp.queue.isQueueDelayable).toEqual(true)
29-
})
30-
3127
it('sets group ID to the file ID', async () => {
3228
mocks.stepQueryResult.mockResolvedValueOnce({
3329
parameters: {
@@ -68,8 +64,4 @@ describe('Queue config', () => {
6864
concurrency: 1,
6965
})
7066
})
71-
72-
it('avoids bursting via a leaky bucket approach', () => {
73-
expect(tilesApp.queue.queueRateLimit.max).toEqual(1)
74-
})
7567
})

packages/backend/src/apps/tiles/queue/index.ts

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
import type { IAppQueue } from '@plumber/types'
22

3-
import { TILES_INTERVAL_BETWEEN_FIND_SINGLE_ROW_MS } from '@/config/app-env-vars/tiles'
43
import Step from '@/models/step'
54

65
// Define actions that should be queued
@@ -38,11 +37,7 @@ const queueSettings = {
3837
type: 'concurrency',
3938
concurrency: 1,
4039
},
41-
isQueueDelayable: true,
42-
queueRateLimit: {
43-
max: 1,
44-
duration: TILES_INTERVAL_BETWEEN_FIND_SINGLE_ROW_MS,
45-
},
40+
isQueueDelayable: false,
4641
} satisfies IAppQueue
4742

4843
export default queueSettings

packages/backend/src/config/app-env-vars/index.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,4 +24,3 @@
2424
import './m365'
2525
import './formsg'
2626
import './postman-sms'
27-
import './tiles'

packages/backend/src/config/app-env-vars/tiles.ts

Lines changed: 0 additions & 4 deletions
This file was deleted.

0 commit comments

Comments
 (0)