Skip to content

Commit a9c895e

Browse files
lint: fix lint
Signed-off-by: Shivanshu Raj Shrivastava <[email protected]>
1 parent 9723550 commit a9c895e

File tree

1 file changed

+11
-9
lines changed
  • instrumentation/opentelemetry-instrumentation-celery/src/opentelemetry/instrumentation/celery

1 file changed

+11
-9
lines changed

instrumentation/opentelemetry-instrumentation-celery/src/opentelemetry/instrumentation/celery/utils.py

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -55,14 +55,14 @@
5555
)
5656

5757

58-
def flatten_dict(d, parent_key="", sep="."):
58+
def flatten_dict(data, parent_key="", sep="."):
5959
items = []
60-
for k, v in d.items():
61-
new_key = f"{parent_key}{sep}{k}" if parent_key else k
62-
if isinstance(v, dict):
63-
items.extend(flatten_dict(v, new_key, sep=sep).items())
60+
for key, value in data.items():
61+
new_key = f"{parent_key}{sep}{key}" if parent_key else key
62+
if isinstance(value, dict):
63+
items.extend(flatten_dict(value, new_key, sep=sep).items())
6464
else:
65-
items.append((new_key, v))
65+
items.append((new_key, value))
6666
return dict(items)
6767

6868

@@ -109,9 +109,11 @@ def set_attributes_from_context(span, context):
109109
# Flatten the dictionary
110110
if value:
111111
flattened = flatten_dict(value)
112-
for k, v in flattened.items():
113-
if v is not None and v != "":
114-
span.set_attribute(f"celery.delivery_info.{k}", v)
112+
for item_key, item_value in flattened.items():
113+
if item_value is not None and item_value != "":
114+
span.set_attribute(
115+
f"celery.delivery_info.{item_key}", item_value
116+
)
115117
continue
116118

117119
elif key == "id":

0 commit comments

Comments
 (0)