diff --git a/dapr_agents/agents/durableagent/agent.py b/dapr_agents/agents/durableagent/agent.py index dda7482..d6de23e 100644 --- a/dapr_agents/agents/durableagent/agent.py +++ b/dapr_agents/agents/durableagent/agent.py @@ -587,7 +587,7 @@ class DurableAgent(AgenticWorkflow, AgentBase): # "messages": [], # "start_time": datetime.now(timezone.utc).isoformat(), # "source": "workflow_start", - # "source_workflow_instance_id": None, + # "triggering_workflow_instance_id": None, # "workflow_name": self._workflow_name, # "dapr_status": "RUNNING", # "suspended_reason": None @@ -597,7 +597,7 @@ class DurableAgent(AgenticWorkflow, AgentBase): # return { # "source": minimal_entry.get("source"), - # "source_workflow_instance_id": minimal_entry.get("source_workflow_instance_id"), + # "triggering_workflow_instance_id": minimal_entry.get("source_workflow_instance_id"), # } @task diff --git a/dapr_agents/workflow/mixins/service.py b/dapr_agents/workflow/mixins/service.py index 467baed..934ef0b 100644 --- a/dapr_agents/workflow/mixins/service.py +++ b/dapr_agents/workflow/mixins/service.py @@ -149,7 +149,7 @@ class ServiceMixin(SignalHandlingMixin): "messages": [], "start_time": datetime.now(timezone.utc).isoformat(), "source": "graceful_shutdown", - "source_workflow_instance_id": None, + "triggering_workflow_instance_id": None, "workflow_name": getattr(self, "_workflow_name", "Unknown"), "dapr_status": DaprWorkflowStatus.PENDING, "suspended_reason": "app_terminated", diff --git a/tests/agents/durableagent/test_durable_agent.py b/tests/agents/durableagent/test_durable_agent.py index 964a5d8..8c41052 100644 --- a/tests/agents/durableagent/test_durable_agent.py +++ b/tests/agents/durableagent/test_durable_agent.py @@ -273,7 +273,7 @@ class TestDurableAgent: ] = DurableAgentWorkflowEntry( input="Test task", source=None, - source_workflow_instance_id="parent-instance-123", + triggering_workflow_instance_id="parent-instance-123", ) workflow_gen = basic_durable_agent.tool_calling_workflow( @@ -288,7 +288,7 @@ class TestDurableAgent: instance_data = basic_durable_agent.state["instances"]["test-instance-123"] assert instance_data.input == "Test task" assert instance_data.source is None - assert instance_data.source_workflow_instance_id == "parent-instance-123" + assert instance_data.triggering_workflow_instance_id == "parent-instance-123" @pytest.mark.asyncio async def test_generate_response_activity(self, basic_durable_agent): @@ -317,7 +317,7 @@ class TestDurableAgent: instance_id: { "input": "Test task", "source": "test_source", - "source_workflow_instance_id": None, + "triggering_workflow_instance_id": None, "messages": [], "tool_history": [], "output": None, @@ -371,7 +371,7 @@ class TestDurableAgent: instance_id: { "input": "Test task", "source": "test_source", - "source_workflow_instance_id": None, + "triggering_workflow_instance_id": None, "messages": [], "tool_history": [], "output": None, @@ -399,7 +399,7 @@ class TestDurableAgent: instance_id: { "input": "Test task", "source": "test_source", - "source_workflow_instance_id": None, + "triggering_workflow_instance_id": None, "messages": [], "tool_history": [], "output": None, diff --git a/tests/agents/durableagent/test_mcp_streamable_http.py b/tests/agents/durableagent/test_mcp_streamable_http.py index 305f794..e848d6a 100644 --- a/tests/agents/durableagent/test_mcp_streamable_http.py +++ b/tests/agents/durableagent/test_mcp_streamable_http.py @@ -164,7 +164,7 @@ async def test_execute_tool_activity_with_mcp_tool(durable_agent_with_mcp_tool): workflow_entry = DurableAgentWorkflowEntry( input="What is 2 plus 2?", source=None, - source_workflow_instance_id=None, + triggering_workflow_instance_id=None, ) durable_agent_with_mcp_tool.state["instances"] = {instance_id: workflow_entry} @@ -263,7 +263,7 @@ async def test_durable_agent_with_real_server_http(start_math_server_http): workflow_entry = DurableAgentWorkflowEntry( input="What is 2 plus 2?", source=None, - source_workflow_instance_id=None, + triggering_workflow_instance_id=None, ) agent.state["instances"] = {instance_id: workflow_entry} # Print available tool names