diff --git a/libraries/nestjs-libraries/src/database/prisma/autopost/autopost.service.ts b/libraries/nestjs-libraries/src/database/prisma/autopost/autopost.service.ts index e455aad3..5964983a 100644 --- a/libraries/nestjs-libraries/src/database/prisma/autopost/autopost.service.ts +++ b/libraries/nestjs-libraries/src/database/prisma/autopost/autopost.service.ts @@ -105,7 +105,7 @@ export class AutopostService { try { return this._temporalService.client .getRawClient() - ?.workflow.start('postWorkflowV101', { + ?.workflow.start('autoPostWorkflow', { workflowId: `autopost-${id}`, taskQueue: 'main', args: [{ id, immediately: true }], diff --git a/libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts b/libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts index fe92a0e9..deabc60b 100644 --- a/libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts +++ b/libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts @@ -384,7 +384,7 @@ export class PostsService { const workflows = this._temporalService.client .getRawClient() ?.workflow.list({ - query: `WorkflowType="postWorkflow" AND postId="${post.id}" AND ExecutionStatus="Running"`, + query: `postId="${post.id}" AND ExecutionStatus="Running"`, }); for await (const executionInfo of workflows) { @@ -444,7 +444,7 @@ export class PostsService { const workflows = this._temporalService.client .getRawClient() ?.workflow.list({ - query: `WorkflowType="postWorkflow" AND postId="${posts[0].id}" AND ExecutionStatus="Running"`, + query: `postId="${posts[0].id}" AND ExecutionStatus="Running"`, }); for await (const executionInfo of workflows) { @@ -513,7 +513,7 @@ export class PostsService { const workflows = this._temporalService.client .getRawClient() ?.workflow.list({ - query: `WorkflowType="postWorkflow" AND postId="${getPostById.id}" AND ExecutionStatus="Running"`, + query: `postId="${getPostById.id}" AND ExecutionStatus="Running"`, }); for await (const executionInfo of workflows) {