Plumb through :use_error_serialization_v2 from Configuration -> GRPC (#…

…296)
coinbase · May 9, 2024 · 34a7e4d · 34a7e4d
1 parent f075102
commit 34a7e4d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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,