File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed
temporalio/lib/temporalio/internal/worker Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change 4
4
require 'temporalio'
5
5
require 'temporalio/activity/definition'
6
6
require 'temporalio/api'
7
+ require 'temporalio/converters/payload_converter'
7
8
require 'temporalio/converters/raw_value'
8
9
require 'temporalio/error'
9
10
require 'temporalio/internal/bridge/api'
@@ -388,9 +389,11 @@ def apply_query(job)
388
389
schedule do
389
390
# If it's a built-in, run it without interceptors, otherwise do normal behavior
390
391
result = if job . query_type == '__stack_trace'
391
- scheduler . stack_trace
392
+ # Use raw value built from default converter because we don't want to use user-conversion
393
+ Converters ::RawValue . new ( Converters ::PayloadConverter . default . to_payload ( scheduler . stack_trace ) )
392
394
elsif job . query_type == '__temporal_workflow_metadata'
393
- workflow_metadata
395
+ # Use raw value built from default converter because we don't want to use user-conversion
396
+ Converters ::RawValue . new ( Converters ::PayloadConverter . default . to_payload ( workflow_metadata ) )
394
397
else
395
398
# Get query definition, falling back to dynamic if not present and not reserved
396
399
defn = query_handlers [ job . query_type ]
You can’t perform that action at this time.
0 commit comments