Skip to content

Commit 90d7dc6

Browse files
Disable cursor nesting
1 parent 10f5f6c commit 90d7dc6

File tree

2 files changed

+2
-6
lines changed

2 files changed

+2
-6
lines changed

lib/mongo/operation/insert/op_msg.rb

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -35,11 +35,7 @@ class OpMsg < OpMsgBase
3535

3636
def get_result(connection, context, options = {})
3737
message = build_message(connection, context)
38-
if (tracer = context.tracer)
39-
tracer.trace_command(message, context, connection) do
40-
Result.new(*dispatch_message(message, connection, context), @ids, context: context)
41-
end
42-
else
38+
connection.tracer.trace_command(message, context, connection) do
4339
Result.new(*dispatch_message(message, connection, context), @ids, context: context)
4440
end
4541
end

lib/mongo/tracing/open_telemetry/command_tracer.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ def span_attributes(message, connection)
7676
end
7777

7878
def process_cursor_context(result, cursor_id, context, span)
79-
if result.respond_to?(:cursor_id) && result.cursor_id.positive?
79+
if result.has_cursor_id? && result.cursor_id.positive?
8080
span.set_attribute('db.mongodb.cursor_id', result.cursor_id)
8181
end
8282
end

0 commit comments

Comments
 (0)