Skip to content

Commit 4e1ccbf

Browse files
committed
fix: Ensures workflowIdConflictPolicy parameter is properly set when not UNSPECIFIED
1 parent 3dac08d commit 4e1ccbf

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

internal/plugin/client.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2382,6 +2382,13 @@ func (m *Manifest) genWorkflowOptions(f *j.File, workflow protoreflect.FullName,
23822382
})
23832383
}
23842384

2385+
// set WorkflowIDConflictPolicy
2386+
if !child {
2387+
g.If(j.Id("v").Op(":=").Id("o").Dot("workflowIdConflictPolicy"), j.Id("v").Op("!=").Qual(enumsPkg, "WORKFLOW_ID_CONFLICT_POLICY_UNSPECIFIED")).Block(
2388+
j.Id("opts").Dot("WorkflowIDConflictPolicy").Op("=").Id("v"),
2389+
)
2390+
}
2391+
23852392
// set TaskQueue
23862393
g.If(j.Id("v").Op(":=").Id("o").Dot("taskQueue"), j.Id("v").Op("!=").Nil()).Block(
23872394
j.Id("opts").Dot("TaskQueue").Op("=").Op("*").Id("v"),

0 commit comments

Comments
 (0)