dapr
/
dapr-agents
mirror of https://github.com/dapr/dapr-agents.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix: [] -> () 

Signed-off-by: Casper Guldbech Nielsen <scni@novonordisk.com>
This commit is contained in:
Casper Guldbech Nielsen 2025-05-03 22:29:33 +02:00
parent b80b75efec
commit 701b8f9884
No known key found for this signature in database
GPG Key ID: B004583B52B9A446
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dapr_agents/workflow/agentic.py
View File

@ -731,9 +731,9 @@ class AgenticWorkflow(WorkflowApp, DaprPubSub, MessageRoutingMixin):
logger.info(f"{self.name} sending message to agent '{name}'.")
span = trace.get_current_span()
span.set_attribute["message.receiver", agent_metadata["topic_name"]]
span.set_attribute["message.sender", self.name]
span.set_attribute["message.message", message]
span.set_attribute("message.receiver", agent_metadata["topic_name"])
span.set_attribute("message.sender", self.name)
span.set_attribute("message.message", message)
await self.publish_event_message(
topic_name=agent_metadata["topic_name"],

4
dapr_agents/workflow/orchestrators/llm/orchestrator.py
View File

@ -110,9 +110,9 @@ class LLMOrchestrator(OrchestratorWorkflowBase):
# Step 0: Retrieve iteration messages
task = message.get("task")
span.set_attribute["message.task", str(task)]
span.set_attribute("message.task", task)
iteration = message.get("iteration")
span.set_attribute["workflow.iteration", str(iteration)]
span.set_attribute("workflow.iteration", iteration)
# Step 1:
# Ensure 'instances' and the instance_id entry exist