jeffemmett
/
postiz
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: workflow termination

This commit is contained in:
Nevo David 2026-01-07 13:57:45 +07:00
parent 2544e870aa
commit 2cc639bbfc
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libraries/nestjs-libraries/src/database/prisma/autopost/autopost.service.ts
View File

@ -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 }],

6
libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts
View File

@ -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) {