feat(quarkus): use .agent-run suffix for child workflow names

Child AgentRunWorkflows now use agent-specific names with .agent-run
suffix (e.g., dapr.langchain4j.WeatherAssistant.agent-run) instead
of the generic "agent" name. This avoids conflicts with orchestration
workflow names (.workflow suffix) while keeping descriptive names
visible in the Dapr dashboard.

Signed-off-by: Javier Aliaga <javier@diagrid.io>

Author: javier-aliaga

quarkus/deployment/src/main/java/io/dapr/quarkus/langchain4j/deployment/DaprAgenticProcessor.java

@@ -287,6 +287,32 @@ void setupWorkflowRuntime(DaprWorkflowRuntimeRecorder recorder,
       recorder.registerAgentName(interfaceName, agentName);
     }
 
+    // Register AgentRunWorkflow under *.agent-run names for ALL agents
+    // (both standalone and composite). Used by orchestration workflows for
+    // child workflows — avoids conflicts with orchestration *.workflow names.
+    for (Map.Entry<DotName, String> entry : AGENT_ANNOTATION_TO_WORKFLOW.entrySet()) {
+      for (AnnotationInstance ann : index.getAnnotations(entry.getKey())) {
+        AnnotationValue nameValue = ann.value("name");
+        if (nameValue == null || nameValue.asString().isEmpty()) {
+          continue;
+        }
+        String runName = "dapr.langchain4j."
+            + toTitleCase(nameValue.asString()) + ".agent-run";
+        recorder.registerWorkflow(builder, runName, agentRunClass);
+      }
+    }
+    for (AnnotationInstance ann : index.getAnnotations(AGENT_ANNOTATION)) {
+      if (ann.target().kind() != AnnotationTarget.Kind.METHOD) {
+        continue;
+      }
+      AnnotationValue nameValue = ann.value("name");
+      if (nameValue != null && !nameValue.asString().isEmpty()) {
+        String runName = "dapr.langchain4j."
+            + toTitleCase(nameValue.asString()) + ".agent-run";
+        recorder.registerWorkflow(builder, runName, agentRunClass);
+      }
+    }
+
     recorder.startRuntime(builder);
   }
 

quarkus/runtime/src/main/java/io/dapr/quarkus/langchain4j/workflow/DaprAgentServiceUtil.java

@@ -76,4 +76,20 @@ public static String agentWorkflowName(String agentName) {
     return "dapr.langchain4j." + toTitleCase(agentName) + ".workflow";
   }
 
+  /**
+   * Returns the child AgentRunWorkflow name for an agent.
+   * Uses {@code .agent-run} suffix to avoid conflicts with orchestration
+   * workflow names (which use {@code .workflow} suffix).
+   *
+   * @param agentName the agent name (e.g., "weather-assistant")
+   * @return the child workflow name (e.g., "dapr.langchain4j.WeatherAssistant.agent-run")
+   */
+  public static String agentRunName(String agentName) {
+    if (agentName == null || agentName.isEmpty()) {
+      return WorkflowNameResolver.resolve(
+          io.dapr.quarkus.langchain4j.agent.workflow.AgentRunWorkflow.class);
+    }
+    return "dapr.langchain4j." + toTitleCase(agentName) + ".agent-run";
+  }
+
 }

quarkus/runtime/src/main/java/io/dapr/quarkus/langchain4j/workflow/orchestration/ConditionalOrchestrationWorkflow.java

@@ -50,8 +50,8 @@ public WorkflowStub create() {
           AgentRunInput agentInput = new AgentRunInput(agentRunId, metadata.agentName(),
               metadata.userMessage(), metadata.systemMessage());
 
-          String childName = DaprAgentServiceUtil.agentWorkflowName(metadata.agentName());
-          var childWorkflow = ctx.callChildWorkflow(childName, agentInput, agentRunId, Void.class);
+          var childWorkflow = ctx.callChildWorkflow(
+              DaprAgentServiceUtil.agentRunName(metadata.agentName()), agentInput, agentRunId, Void.class);
           // Submit agent to planner (non-blocking activity — returns immediately)
           ctx.callActivity("agent-call",
               new AgentExecInput(input.plannerId(), i, agentRunId), Void.class).await();

quarkus/runtime/src/main/java/io/dapr/quarkus/langchain4j/workflow/orchestration/LoopOrchestrationWorkflow.java

@@ -59,8 +59,8 @@ public WorkflowStub create() {
           AgentRunInput agentInput = new AgentRunInput(agentRunId, metadata.agentName(),
               metadata.userMessage(), metadata.systemMessage());
 
-          String childName = DaprAgentServiceUtil.agentWorkflowName(metadata.agentName());
-          var childWorkflow = ctx.callChildWorkflow(childName, agentInput, agentRunId, Void.class);
+          var childWorkflow = ctx.callChildWorkflow(
+              DaprAgentServiceUtil.agentRunName(metadata.agentName()), agentInput, agentRunId, Void.class);
           // Submit agent to planner (non-blocking activity -- returns immediately)
           ctx.callActivity("agent-call",
               new AgentExecInput(input.plannerId(), i, agentRunId), Void.class).await();

quarkus/runtime/src/main/java/io/dapr/quarkus/langchain4j/workflow/orchestration/ParallelOrchestrationWorkflow.java

@@ -54,8 +54,8 @@ public WorkflowStub create() {
             metadata.userMessage(), metadata.systemMessage());
 
         // Start AgentRunWorkflow as a child workflow with agent-specific name
-        String childName = DaprAgentServiceUtil.agentWorkflowName(metadata.agentName());
-        childWorkflows.add(ctx.callChildWorkflow(childName, agentInput, agentRunId, Void.class));
+        childWorkflows.add(ctx.callChildWorkflow(
+              DaprAgentServiceUtil.agentRunName(metadata.agentName()), agentInput, agentRunId, Void.class));
         // Submit agent to planner (non-blocking activity -- returns immediately)
         submitTasks.add(ctx.callActivity("agent-call",
             new AgentExecInput(input.plannerId(), i, agentRunId), Void.class));

quarkus/runtime/src/main/java/io/dapr/quarkus/langchain4j/workflow/orchestration/SequentialOrchestrationWorkflow.java

@@ -45,9 +45,10 @@ public WorkflowStub create() {
         AgentRunInput agentInput = new AgentRunInput(agentRunId, metadata.agentName(),
             metadata.userMessage(), metadata.systemMessage());
 
-        // Start AgentRunWorkflow as a child workflow with agent-specific name
-        String childWorkflowName = DaprAgentServiceUtil.agentWorkflowName(metadata.agentName());
-        var childWorkflow = ctx.callChildWorkflow(childWorkflowName, agentInput, agentRunId, Void.class);
+        // Start AgentRunWorkflow as child with agent-specific .agent-run name
+        var childWorkflow = ctx.callChildWorkflow(
+            DaprAgentServiceUtil.agentRunName(metadata.agentName()),
+            agentInput, agentRunId, Void.class);
         // Submit agent to planner (non-blocking activity — returns immediately)
         ctx.callActivity("agent-call",
             new AgentExecInput(input.plannerId(), i, agentRunId), Void.class).await();