From 34a7e4d8559f1c6da517f9f3e30168c4c10bd098 Mon Sep 17 00:00:00 2001 From: David Hughes Date: Thu, 9 May 2024 14:49:54 -0700 Subject: [PATCH] Plumb through :use_error_serialization_v2 from Configuration -> GRPC (#296) --- lib/temporal/configuration.rb | 2 +- lib/temporal/connection/grpc.rb | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/temporal/configuration.rb b/lib/temporal/configuration.rb index a2c895bc..014187c1 100644 --- a/lib/temporal/configuration.rb +++ b/lib/temporal/configuration.rb @@ -122,7 +122,7 @@ def for_connection port: port, credentials: credentials, identity: identity || default_identity, - connection_options: connection_options + connection_options: connection_options.merge(use_error_serialization_v2: @use_error_serialization_v2) ).freeze end diff --git a/lib/temporal/connection/grpc.rb b/lib/temporal/connection/grpc.rb index 1bec78f2..fa246e9f 100644 --- a/lib/temporal/connection/grpc.rb +++ b/lib/temporal/connection/grpc.rb @@ -311,7 +311,7 @@ def respond_activity_task_completed_by_id(namespace:, activity_id:, workflow_id: end def respond_activity_task_failed(namespace:, task_token:, exception:) - serialize_whole_error = Temporal.configuration.use_error_serialization_v2 + serialize_whole_error = options.fetch(:use_error_serialization_v2, Temporal.configuration.use_error_serialization_v2) request = Temporalio::Api::WorkflowService::V1::RespondActivityTaskFailedRequest.new( namespace: namespace, identity: identity,