@@ -70,6 +70,10 @@ async def run():
70
70
self .assertEqual (len (spans ), 1 )
71
71
self .assertEqual (spans [0 ].name , "SELECT :memory:" )
72
72
self .assertEqual (spans [0 ].kind , trace .SpanKind .CLIENT )
73
+ self .assertEqual (
74
+ spans [0 ].instrumentation_scope .name ,
75
+ "opentelemetry.instrumentation.sqlalchemy" ,
76
+ )
73
77
74
78
asyncio .get_event_loop ().run_until_complete (run ())
75
79
@@ -104,6 +108,10 @@ def test_create_engine_wrapper(self):
104
108
self .assertEqual (len (spans ), 1 )
105
109
self .assertEqual (spans [0 ].name , "SELECT :memory:" )
106
110
self .assertEqual (spans [0 ].kind , trace .SpanKind .CLIENT )
111
+ self .assertEqual (
112
+ spans [0 ].instrumentation_scope .name ,
113
+ "opentelemetry.instrumentation.sqlalchemy" ,
114
+ )
107
115
108
116
def test_custom_tracer_provider (self ):
109
117
provider = TracerProvider (
@@ -154,6 +162,10 @@ async def run():
154
162
self .assertEqual (len (spans ), 1 )
155
163
self .assertEqual (spans [0 ].name , "SELECT :memory:" )
156
164
self .assertEqual (spans [0 ].kind , trace .SpanKind .CLIENT )
165
+ self .assertEqual (
166
+ spans [0 ].instrumentation_scope .name ,
167
+ "opentelemetry.instrumentation.sqlalchemy" ,
168
+ )
157
169
158
170
asyncio .get_event_loop ().run_until_complete (run ())
159
171
0 commit comments