Skip to content

Commit 06c0ebc

Browse files
authoredMay 21, 2024··
Add SetFailureConverter to the activity and workflow test environments (#1484)
1 parent 725b428 commit 06c0ebc

File tree

2 files changed

+16
-0
lines changed

2 files changed

+16
-0
lines changed
 

‎internal/internal_workflow_testsuite.go

+4
Original file line numberDiff line numberDiff line change
@@ -451,6 +451,10 @@ func (env *testWorkflowEnvironmentImpl) setDataConverter(dataConverter converter
451451
env.dataConverter = dataConverter
452452
}
453453

454+
func (env *testWorkflowEnvironmentImpl) setFailureConverter(failureConverter converter.FailureConverter) {
455+
env.failureConverter = failureConverter
456+
}
457+
454458
func (env *testWorkflowEnvironmentImpl) setContextPropagators(contextPropagators []ContextPropagator) {
455459
env.contextPropagators = contextPropagators
456460
}

‎internal/workflow_testsuite.go

+12
Original file line numberDiff line numberDiff line change
@@ -214,6 +214,12 @@ func (t *TestActivityEnvironment) SetDataConverter(dataConverter converter.DataC
214214
return t
215215
}
216216

217+
// SetFailureConverter sets the failure converter.
218+
func (t *TestActivityEnvironment) SetFailureConverter(failureConverter converter.FailureConverter) *TestActivityEnvironment {
219+
t.impl.setFailureConverter(failureConverter)
220+
return t
221+
}
222+
217223
// SetIdentity sets identity.
218224
func (t *TestActivityEnvironment) SetIdentity(identity string) *TestActivityEnvironment {
219225
t.impl.setIdentity(identity)
@@ -649,6 +655,12 @@ func (e *TestWorkflowEnvironment) SetDataConverter(dataConverter converter.DataC
649655
return e
650656
}
651657

658+
// SetFailureConverter sets the failure converter.
659+
func (t *TestWorkflowEnvironment) SetFailureConverter(failureConverter converter.FailureConverter) *TestWorkflowEnvironment {
660+
t.impl.setFailureConverter(failureConverter)
661+
return t
662+
}
663+
652664
// SetContextPropagators sets context propagators.
653665
func (e *TestWorkflowEnvironment) SetContextPropagators(contextPropagators []ContextPropagator) *TestWorkflowEnvironment {
654666
e.impl.setContextPropagators(contextPropagators)

0 commit comments

Comments
 (0)
Please sign in to comment.