Skip to content

Commit a5a0777

Browse files
committed
fix: prevent premature workflow cancellation in members-enrichment
1 parent 75c85a6 commit a5a0777

3 files changed

Lines changed: 5 additions & 5 deletions

File tree

services/apps/members_enrichment_worker/src/schedules/getMembersToEnrich.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ export const scheduleMembersEnrichment = async () => {
2424
type: 'startWorkflow',
2525
workflowType: getMembersToEnrich,
2626
taskQueue: 'members-enrichment',
27-
workflowExecutionTimeout: '20 minutes',
27+
workflowExecutionTimeout: '45 minutes',
2828
retry: {
2929
initialInterval: '15 seconds',
3030
backoffCoefficient: 2,

services/apps/members_enrichment_worker/src/workflows/enrichMember.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ const {
2424
hasRemainingCredits,
2525
getMemberById,
2626
} = proxyActivities<typeof activities>({
27-
startToCloseTimeout: '5 minutes',
27+
startToCloseTimeout: '10 minutes',
2828
retry: {
2929
initialInterval: '60s',
3030
backoffCoefficient: 2.0,
@@ -82,7 +82,7 @@ export async function enrichMember(
8282
workflowId: 'member-enrichment/' + input.id + '/processMemberSources',
8383
cancellationType: ChildWorkflowCancellationType.WAIT_CANCELLATION_COMPLETED,
8484
parentClosePolicy: ParentClosePolicy.PARENT_CLOSE_POLICY_REQUEST_CANCEL,
85-
workflowExecutionTimeout: '15 minutes',
85+
workflowExecutionTimeout: '25 minutes',
8686
retry: {
8787
backoffCoefficient: 2,
8888
maximumAttempts: 10,

services/apps/members_enrichment_worker/src/workflows/getMembersToEnrich.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ import { chunkArray } from '../utils/common'
1414
import { enrichMember } from './enrichMember'
1515

1616
const { getEnrichableMembers, getMaxConcurrentRequests } = proxyActivities<typeof activities>({
17-
startToCloseTimeout: '10 minutes',
17+
startToCloseTimeout: '15 minutes',
1818
})
1919

2020
export async function getMembersToEnrich(): Promise<void> {
@@ -46,7 +46,7 @@ export async function getMembersToEnrich(): Promise<void> {
4646
workflowId: 'member-enrichment/' + member.id,
4747
cancellationType: ChildWorkflowCancellationType.WAIT_CANCELLATION_COMPLETED,
4848
parentClosePolicy: ParentClosePolicy.PARENT_CLOSE_POLICY_REQUEST_CANCEL,
49-
workflowExecutionTimeout: '15 minutes',
49+
workflowExecutionTimeout: '30 minutes',
5050
retry: {
5151
backoffCoefficient: 2,
5252
maximumAttempts: 10,

0 commit comments

Comments
 (0)