Skip to content

Commit

Permalink
Reformat files
Browse files Browse the repository at this point in the history
  • Loading branch information
mpozniak95 committed Aug 26, 2024
1 parent 5507098 commit da7ae34
Showing 1 changed file with 12 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -237,7 +237,9 @@ def _traced_execute_pipeline(func, instance, args, kwargs):

def _traced_create_index(func, instance, args, kwargs):
span_name = "redis.create_index"
with tracer.start_as_current_span(span_name, kind=trace.SpanKind.CLIENT) as span:
with tracer.start_as_current_span(
span_name, kind=trace.SpanKind.CLIENT
) as span:
_set_span_attribute(
span,
SpanAttributes.DB_SYSTEM,
Expand All @@ -247,7 +249,9 @@ def _traced_create_index(func, instance, args, kwargs):
if fields:
field_attribute = ""
for field in fields:
field_attribute += f"Field(name: {field.name}, type: {field.args[0]});"
field_attribute += (
f"Field(name: {field.name}, type: {field.args[0]});"
)
_set_span_attribute(
span,
"redis.create_index.fields",
Expand All @@ -258,7 +262,9 @@ def _traced_create_index(func, instance, args, kwargs):

def _traced_search(func, instance, args, kwargs):
span_name = "redis.search"
with tracer.start_as_current_span(span_name, kind=trace.SpanKind.CLIENT) as span:
with tracer.start_as_current_span(
span_name, kind=trace.SpanKind.CLIENT
) as span:
_set_span_attribute(
span,
SpanAttributes.DB_SYSTEM,
Expand All @@ -285,7 +291,9 @@ def _traced_search(func, instance, args, kwargs):

def _traced_aggregate(func, instance, args, kwargs):
span_name = "redis.aggregate"
with tracer.start_as_current_span(span_name, kind=trace.SpanKind.CLIENT) as span:
with tracer.start_as_current_span(
span_name, kind=trace.SpanKind.CLIENT
) as span:
_set_span_attribute(
span,
SpanAttributes.DB_SYSTEM,
Expand Down

0 comments on commit da7ae34

Please sign in to comment.