fm453/nocobase
1
0
Fork 0
mirror of https://gitee.com/nocobase/nocobase.git synced 2025-07-02 11:12:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'main' into next

Browse Source
This commit is contained in:
nocobase[bot] 2025-01-17 15:46:56 +00:00
commit 222b4bc9da
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
packages/plugins/@nocobase/plugin-workflow/src/server/Plugin.ts
View File

@ -417,7 +417,7 @@ export default class PluginWorkflowServer extends Plugin {
}
// NOTE: no await for quick return
setTimeout(this.prepare);
setImmediate(this.prepare);
}
private async triggerSync(
@ -463,6 +463,7 @@ export default class PluginWorkflowServer extends Plugin {
if (execution.status !== EXECUTION_STATUS.STARTED) {
return;
}
this.getLogger(execution.workflowId).info(`starting deferred execution (${execution.id})`);
this.pending.push([execution]);
if (this.executing) {
await this.executing;
@ -591,6 +592,10 @@ export default class PluginWorkflowServer extends Plugin {
if (this.events.length) {
await this.prepare();
} else {
this.getLogger('dispatcher').info('no more events need to be prepared, dispatching...');
if (this.executing) {
await this.executing;
}
this.dispatch();
}
};
@ -656,7 +661,7 @@ export default class PluginWorkflowServer extends Plugin {
}
this.executing = null;
if (next) {
if (next || this.pending.length) {
this.getLogger('dispatcher').info(`last process finished, will do another dispatch`);
this.dispatch();
}
@ -668,11 +673,12 @@ export default class PluginWorkflowServer extends Plugin {
}
private async process(execution: ExecutionModel, job?: JobModel, options: Transactionable = {}): Promise<Processor> {
const logger = this.getLogger(execution.workflowId);
if (execution.status === EXECUTION_STATUS.QUEUEING) {
const transaction = await this.useDataSourceTransaction('main', options.transaction);
await execution.update({ status: EXECUTION_STATUS.STARTED }, { transaction });
logger.info(`queueing execution (${execution.id}) from pending list updated to started`);
}
const logger = this.getLogger(execution.workflowId);
const processor = this.createProcessor(execution, options);
logger.info(`execution (${execution.id}) ${job ? 'resuming' : 'starting'}...`);