Skip to content

Commit 4da0ee9

Browse files
authored
fix(#27): added worker options with custom serializer for types (#28)
1 parent 841193e commit 4da0ee9

File tree

1 file changed

+15
-0
lines changed

1 file changed

+15
-0
lines changed

src/Migrator/ServiceCollectionExtensions.cs

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,21 @@ public static ITemporalMigratorBuilder AddTemporalMigrations(
5353

5454
var workerOptionsBuilder = services
5555
.AddHostedTemporalWorker(clientTargetHost, clientNamespace, taskQueue, buildId)
56+
.ConfigureOptions(options =>
57+
{
58+
var serializerOptions = new JsonSerializerOptions();
59+
serializerOptions.Converters.Add(new TypeJsonConverter());
60+
61+
options.Interceptors = [new TracingInterceptor()];
62+
63+
if (options.ClientOptions is null)
64+
{
65+
return;
66+
}
67+
68+
options.ClientOptions.DataConverter = new DataConverter(new DefaultPayloadConverter(serializerOptions), new DefaultFailureConverter());
69+
options.ClientOptions.Interceptors = [new TracingInterceptor()];
70+
})
5671
.AddWorkflow<MigrationWorkflow>()
5772
.AddSingletonActivities<MigrationActivities>();
5873

0 commit comments

Comments
 (0)