Thomas Trompette
2025-09-15 17:31:12 +02:00
committed by GitHub
parent 069956ce92
commit 2f1efa68ad
4 changed files with 13 additions and 7 deletions
@@ -9,14 +9,14 @@ import { isCodeOutputSchema } from './isCodeOutputSchema';
import { isDatabaseEventTriggerOutputSchema } from './isDatabaseEventTriggerOutputSchema';
import { isFindRecordsOutputSchema } from './isFindRecordsOutputSchema';
import { isFormOutputSchema } from './isFormOutputSchema';
import { isRecordActionOutputSchema } from './isRecordActionOutputSchema';
import { isRecordStepOutputSchema } from './isRecordStepOutputSchema';
export const isOpenStepOutputSchema = (
stepType: WorkflowActionType | WorkflowTriggerType,
schema: OutputSchemaV2,
): schema is OpenStepOutputSchema => {
return (
!isRecordActionOutputSchema(stepType, schema) &&
!isRecordStepOutputSchema(stepType, schema) &&
!isDatabaseEventTriggerOutputSchema(stepType, schema) &&
!isFindRecordsOutputSchema(stepType, schema) &&
!isFormOutputSchema(stepType, schema) &&
@@ -5,11 +5,16 @@ import {
import { type RecordActionOutputSchema } from '@/workflow/workflow-variables/types/RecordActionOutputSchema';
import { type OutputSchemaV2 } from '@/workflow/workflow-variables/types/StepOutputSchemaV2';
const RECORD_ACTION_TYPES = ['CREATE_RECORD', 'UPDATE_RECORD', 'DELETE_RECORD'];
const RECORD_STEP_TYPES = [
'CREATE_RECORD',
'UPDATE_RECORD',
'DELETE_RECORD',
'MANUAL',
];
export const isRecordActionOutputSchema = (
export const isRecordStepOutputSchema = (
stepType: WorkflowActionType | WorkflowTriggerType,
schema: OutputSchemaV2,
): schema is RecordActionOutputSchema => {
return RECORD_ACTION_TYPES.includes(stepType);
return RECORD_STEP_TYPES.includes(stepType);
};
@@ -6,7 +6,7 @@ import { isCodeOutputSchema } from '@/workflow/workflow-variables/types/guards/i
import { isDatabaseEventTriggerOutputSchema } from '@/workflow/workflow-variables/types/guards/isDatabaseEventTriggerOutputSchema';
import { isFindRecordsOutputSchema } from '@/workflow/workflow-variables/types/guards/isFindRecordsOutputSchema';
import { isFormOutputSchema } from '@/workflow/workflow-variables/types/guards/isFormOutputSchema';
import { isRecordActionOutputSchema } from '@/workflow/workflow-variables/types/guards/isRecordActionOutputSchema';
import { isRecordStepOutputSchema } from '@/workflow/workflow-variables/types/guards/isRecordStepOutputSchema';
import { type StepOutputSchemaV2 } from '@/workflow/workflow-variables/types/StepOutputSchemaV2';
import { searchVariableThroughBaseOutputSchema } from '@/workflow/workflow-variables/utils/searchVariableThroughBaseOutputSchema';
@@ -27,7 +27,7 @@ export const searchVariableThroughOutputSchemaV2 = ({
rawVariableName: string;
isFullRecord: boolean;
}) => {
if (isRecordActionOutputSchema(stepType, stepOutputSchema.outputSchema)) {
if (isRecordStepOutputSchema(stepType, stepOutputSchema.outputSchema)) {
return searchVariableThroughRecordOutputSchema({
stepName: stepOutputSchema.name,
recordOutputSchema: stepOutputSchema.outputSchema,
@@ -128,6 +128,7 @@ export class WorkflowStatusesUpdateJob {
where: {
id: workflowId,
},
withDeleted: true,
});
if (isEqual(newWorkflowStatuses, previousWorkflow.statuses)) {