diff --git a/src/Migrator/ServiceCollectionExtensions.cs b/src/Migrator/ServiceCollectionExtensions.cs index 4cff427..29aef47 100644 --- a/src/Migrator/ServiceCollectionExtensions.cs +++ b/src/Migrator/ServiceCollectionExtensions.cs @@ -53,6 +53,21 @@ public static ITemporalMigratorBuilder AddTemporalMigrations( var workerOptionsBuilder = services .AddHostedTemporalWorker(clientTargetHost, clientNamespace, taskQueue, buildId) + .ConfigureOptions(options => + { + var serializerOptions = new JsonSerializerOptions(); + serializerOptions.Converters.Add(new TypeJsonConverter()); + + options.Interceptors = [new TracingInterceptor()]; + + if (options.ClientOptions is null) + { + return; + } + + options.ClientOptions.DataConverter = new DataConverter(new DefaultPayloadConverter(serializerOptions), new DefaultFailureConverter()); + options.ClientOptions.Interceptors = [new TracingInterceptor()]; + }) .AddWorkflow() .AddSingletonActivities();