mirror of
https://github.com/n8n-io/n8n.git
synced 2025-03-05 20:50:17 -08:00
* Unify execution ID across executions * Fix indentation and improved comments * WIP: saving data after each node execution * Added on/off to save data after each step, saving initial data and retries working * Fixing lint issues * Fixing more lint issues * ✨ Add bull to execute workflows * 👕 Fix lint issue * ⚡ Add graceful shutdown to worker * ⚡ Add loading staticData to worker * 👕 Fix lint issue * ⚡ Fix import * Changed tables metadata to add nullable to stoppedAt * Reload database on migration run * Fixed reloading database schema for sqlite by reconnecting and fixing postgres migration * Added checks to Redis and exiting process if connection is unavailable * Fixing error with new installations * Fix issue with data not being sent back to browser on manual executions with defined destination * Merging bull and unify execution id branch fixes * Main process will now get execution success from database instead of redis * Omit execution duration if execution did not stop * Fix issue with execution list displaying inconsistant information information while a workflow is running * Remove unused hooks to clarify for developers that these wont run in queue mode * Added active pooling to help recover from Redis crashes * Lint issues * Changing default polling interval to 60 seconds * Removed unnecessary attributes from bull job * ⚡ Improved output on worker job start Co-authored-by: Jan Oberhauser <jan.oberhauser@gmail.com>
53 lines
733 B
TypeScript
53 lines
733 B
TypeScript
import {
|
|
WorkflowExecuteMode,
|
|
} from 'n8n-workflow';
|
|
|
|
import {
|
|
IExecutionFlattedDb,
|
|
IWorkflowDb,
|
|
} from '../../';
|
|
|
|
import {
|
|
Column,
|
|
Entity,
|
|
Index,
|
|
PrimaryGeneratedColumn,
|
|
} from 'typeorm';
|
|
|
|
|
|
@Entity()
|
|
export class ExecutionEntity implements IExecutionFlattedDb {
|
|
|
|
@PrimaryGeneratedColumn()
|
|
id: number;
|
|
|
|
@Column('text')
|
|
data: string;
|
|
|
|
@Column()
|
|
finished: boolean;
|
|
|
|
@Column('varchar')
|
|
mode: WorkflowExecuteMode;
|
|
|
|
@Column({ nullable: true })
|
|
retryOf: string;
|
|
|
|
@Column({ nullable: true })
|
|
retrySuccessId: string;
|
|
|
|
@Column()
|
|
startedAt: Date;
|
|
|
|
@Index()
|
|
@Column({ nullable: true })
|
|
stoppedAt: Date;
|
|
|
|
@Column('simple-json')
|
|
workflowData: IWorkflowDb;
|
|
|
|
@Index()
|
|
@Column({ nullable: true })
|
|
workflowId: string;
|
|
}
|