Skip to content

Commit

Permalink
lint: fix lint
Browse files Browse the repository at this point in the history
Signed-off-by: Shivanshu Raj Shrivastava <[email protected]>
  • Loading branch information
shivanshuraj1333 committed Feb 19, 2025
1 parent 9723550 commit a9c895e
Showing 1 changed file with 11 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -55,14 +55,14 @@
)


def flatten_dict(d, parent_key="", sep="."):
def flatten_dict(data, parent_key="", sep="."):
items = []
for k, v in d.items():
new_key = f"{parent_key}{sep}{k}" if parent_key else k
if isinstance(v, dict):
items.extend(flatten_dict(v, new_key, sep=sep).items())
for key, value in data.items():
new_key = f"{parent_key}{sep}{key}" if parent_key else key
if isinstance(value, dict):
items.extend(flatten_dict(value, new_key, sep=sep).items())
else:
items.append((new_key, v))
items.append((new_key, value))
return dict(items)


Expand Down Expand Up @@ -109,9 +109,11 @@ def set_attributes_from_context(span, context):
# Flatten the dictionary
if value:
flattened = flatten_dict(value)
for k, v in flattened.items():
if v is not None and v != "":
span.set_attribute(f"celery.delivery_info.{k}", v)
for item_key, item_value in flattened.items():
if item_value is not None and item_value != "":
span.set_attribute(
f"celery.delivery_info.{item_key}", item_value
)
continue

elif key == "id":
Expand Down

0 comments on commit a9c895e

Please sign in to comment.