mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-01-25 11:31:38 -08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

wip: addressing PR feedback

Browse source
This commit is contained in:
Eugene Molodkin 2025-01-10 14:34:05 +01:00
parent 37bd0aa655
commit f47e45cd2a
No known key found for this signature in database
2 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
packages/cli/src/concurrency/__tests__/concurrency-control.service.test.ts
View file

@ -1,7 +1,7 @@
import { mock } from 'jest-mock-extended';
import type { WorkflowExecuteMode as ExecutionMode } from 'n8n-workflow';
import type { ConcurrencyType } from '@/concurrency/concurrency-control.service';
import type { ConcurrencyQueueType } from '@/concurrency/concurrency-control.service';
import {
CLOUD_TEMP_PRODUCTION_LIMIT,
CLOUD_TEMP_REPORTABLE_THRESHOLDS,
@ -34,7 +34,7 @@ describe('ConcurrencyControlService', () => {
describe('constructor', () => {
it.each(['production', 'evaluation'])(
'should be enabled if %s cap is positive',
(type: ConcurrencyType) => {
(type: ConcurrencyQueueType) => {
/**
* Arrange
*/
@ -64,7 +64,7 @@ describe('ConcurrencyControlService', () => {
it.each(['production', 'evaluation'])(
'should throw if %s cap is 0',
(type: ConcurrencyType) => {
(type: ConcurrencyQueueType) => {
/**
* Arrange
*/
@ -110,7 +110,7 @@ describe('ConcurrencyControlService', () => {
it.each(['production', 'evaluation'])(
'should be disabled if %s cap is lower than -1',
(type: ConcurrencyType) => {
(type: ConcurrencyQueueType) => {
/**
* Arrange
*/
@ -410,7 +410,7 @@ describe('ConcurrencyControlService', () => {
describe('removeAll', () => {
it.each(['production', 'evaluation'])(
'should remove all executions from the %s queue',
async (type: ConcurrencyType) => {
async (type: ConcurrencyQueueType) => {
/**
* Arrange
*/
@ -701,7 +701,7 @@ describe('ConcurrencyControlService', () => {
*/
expect(telemetry.track).toHaveBeenCalledWith('User hit concurrency limit', {
threshold,
concurrencyType: 'production',
concurrencyQueue: 'production',
});
},
);

4
packages/cli/src/events/maps/relay.event-map.ts
View file

@ -6,7 +6,7 @@ import type {
IWorkflowExecutionDataProcess,
} from 'n8n-workflow';
import type { ConcurrencyType } from '@/concurrency/concurrency-control.service';
import type { ConcurrencyQueueType } from '@/concurrency/concurrency-control.service';
import type { AuthProviderType } from '@/databases/entities/auth-identity';
import type { ProjectRole } from '@/databases/entities/project-relation';
import type { GlobalRole, User } from '@/databases/entities/user';
@ -339,7 +339,7 @@ export type RelayEventMap = {
'execution-throttled': {
executionId: string;
type: ConcurrencyType;
type: ConcurrencyQueueType;
};
'execution-started-during-bootup': {