@@ -50,7 +50,8 @@ def setUpClass(cls):
50
50
def setUp (self ):
51
51
self ._span_exporter .clear ()
52
52
53
- def validate_spans (self , spans : typing .Tuple [Span ]):
53
+ def validate_spans (self ):
54
+ spans = self ._span_exporter .get_finished_spans ()
54
55
self .assertEqual (len (spans ), 2 )
55
56
for span in spans :
56
57
if span .name == "rootSpan" :
@@ -59,6 +60,8 @@ def validate_spans(self, spans: typing.Tuple[Span]):
59
60
pymongo_span = span
60
61
self .assertIsInstance (span .start_time , int )
61
62
self .assertIsInstance (span .end_time , int )
63
+ self .assertIsNot (root_span , None )
64
+ self .assertIsNot (pymongo_span , None )
62
65
self .assertIsNotNone (pymongo_span .parent )
63
66
self .assertEqual (pymongo_span .parent .name , root_span .name )
64
67
self .assertIs (pymongo_span .kind , trace_api .SpanKind .CLIENT )
@@ -79,7 +82,7 @@ def test_insert(self):
79
82
self ._collection .insert_one (
80
83
{"name" : "testName" , "value" : "testValue" }
81
84
)
82
- self .validate_spans (self . _span_exporter . get_finished_spans () )
85
+ self .validate_spans ()
83
86
84
87
def test_update (self ):
85
88
"""Should create a child span for update
@@ -88,18 +91,18 @@ def test_update(self):
88
91
self ._collection .update_one (
89
92
{"name" : "testName" }, {"$set" : {"value" : "someOtherValue" }}
90
93
)
91
- self .validate_spans (self . _span_exporter . get_finished_spans () )
94
+ self .validate_spans ()
92
95
93
96
def test_find (self ):
94
97
"""Should create a child span for find
95
98
"""
96
99
with self ._tracer .start_as_current_span ("rootSpan" ):
97
100
self ._collection .find_one ()
98
- self .validate_spans (self . _span_exporter . get_finished_spans () )
101
+ self .validate_spans ()
99
102
100
103
def test_delete (self ):
101
104
"""Should create a child span for delete
102
105
"""
103
106
with self ._tracer .start_as_current_span ("rootSpan" ):
104
107
self ._collection .delete_one ({"name" : "testName" })
105
- self .validate_spans (self . _span_exporter . get_finished_spans () )
108
+ self .validate_spans ()
0 commit comments