@@ -237,7 +237,9 @@ def _traced_execute_pipeline(func, instance, args, kwargs):
237
237
238
238
def _traced_create_index (func , instance , args , kwargs ):
239
239
span_name = "redis.create_index"
240
- with tracer .start_as_current_span (span_name , kind = trace .SpanKind .CLIENT ) as span :
240
+ with tracer .start_as_current_span (
241
+ span_name , kind = trace .SpanKind .CLIENT
242
+ ) as span :
241
243
_set_span_attribute (
242
244
span ,
243
245
SpanAttributes .DB_SYSTEM ,
@@ -247,7 +249,9 @@ def _traced_create_index(func, instance, args, kwargs):
247
249
if fields :
248
250
field_attribute = ""
249
251
for field in fields :
250
- field_attribute += f"Field(name: { field .name } , type: { field .args [0 ]} );"
252
+ field_attribute += (
253
+ f"Field(name: { field .name } , type: { field .args [0 ]} );"
254
+ )
251
255
_set_span_attribute (
252
256
span ,
253
257
"redis.create_index.fields" ,
@@ -258,7 +262,9 @@ def _traced_create_index(func, instance, args, kwargs):
258
262
259
263
def _traced_search (func , instance , args , kwargs ):
260
264
span_name = "redis.search"
261
- with tracer .start_as_current_span (span_name , kind = trace .SpanKind .CLIENT ) as span :
265
+ with tracer .start_as_current_span (
266
+ span_name , kind = trace .SpanKind .CLIENT
267
+ ) as span :
262
268
_set_span_attribute (
263
269
span ,
264
270
SpanAttributes .DB_SYSTEM ,
@@ -285,7 +291,9 @@ def _traced_search(func, instance, args, kwargs):
285
291
286
292
def _traced_aggregate (func , instance , args , kwargs ):
287
293
span_name = "redis.aggregate"
288
- with tracer .start_as_current_span (span_name , kind = trace .SpanKind .CLIENT ) as span :
294
+ with tracer .start_as_current_span (
295
+ span_name , kind = trace .SpanKind .CLIENT
296
+ ) as span :
289
297
_set_span_attribute (
290
298
span ,
291
299
SpanAttributes .DB_SYSTEM ,
0 commit comments