feat(consumption): Add Invoke Nested Agent operation for Consumption Logic Apps (#8660)

Bhavd13 · web-flow · commit e8f0c76eb06b · 2026-02-24T07:58:28.000-08:00
* Adding Invoke Nested Agent operation

* Reset package files to main

* Adding Unit Tests

* Making task message mandatory

* Filtering for nested agent operation
diff --git a/Localize/lang/strings.json b/Localize/lang/strings.json
@@ -1218,6 +1218,7 @@
   "QHdKnm": "Drag and connect nodes to transform",
   "QIzNzB": "Toggle the agent log panel.",
   "QKC8fv": "Enter variable name",
+  "QMuDPI": "Select workflow with an Agent loop",
   "QMyMOI": "Description",
   "QNfUf/": "Full screen",
   "QT4IaP": "Filtered!",
@@ -2870,6 +2871,7 @@
   "_QHdKnm.comment": "default placeholder text",
   "_QIzNzB.comment": "Toggle the agent log panel aria label text",
   "_QKC8fv.comment": "Placeholder for variable name",
+  "_QMuDPI.comment": "Select workflow with an Agent loop",
   "_QMyMOI.comment": "Description label",
   "_QNfUf/.comment": "Full Screen token picker",
   "_QT4IaP.comment": "Filtered text",
diff --git a/apps/Standalone/src/designer/app/AzureLogicAppsDesigner/laDesignerConsumption.tsx b/apps/Standalone/src/designer/app/AzureLogicAppsDesigner/laDesignerConsumption.tsx
@@ -427,6 +427,7 @@ const getDesignerServices = (
     ...defaultServiceParams,
     clientSupportedOperations: [
       ['/connectionProviders/workflow', 'invokeWorkflow'],
+      ['/connectionProviders/workflow', 'invokenestedagent'],
       ['connectionProviders/xmlOperations', 'xmlValidation'],
       ['connectionProviders/xmlOperations', 'xmlTransform'],
       ['connectionProviders/liquidOperations', 'liquidJsonToJson'],
diff --git a/apps/Standalone/src/designer/app/AzureLogicAppsDesigner/laDesignerConsumptionV2.tsx b/apps/Standalone/src/designer/app/AzureLogicAppsDesigner/laDesignerConsumptionV2.tsx
@@ -582,6 +582,7 @@ const getDesignerServices = (
     ...defaultServiceParams,
     clientSupportedOperations: [
       ['/connectionProviders/workflow', 'invokeWorkflow'],
+      ['/connectionProviders/workflow', 'invokenestedagent'],
       ['connectionProviders/xmlOperations', 'xmlValidation'],
       ['connectionProviders/xmlOperations', 'xmlTransform'],
       ['connectionProviders/liquidOperations', 'liquidJsonToJson'],
diff --git a/apps/Standalone/src/templates/app/TemplatesConsumption.tsx b/apps/Standalone/src/templates/app/TemplatesConsumption.tsx
@@ -366,6 +366,7 @@ const getResourceBasedServices = (
     ...defaultServiceParams,
     clientSupportedOperations: [
       ['/connectionProviders/workflow', 'invokeWorkflow'],
+      ['/connectionProviders/workflow', 'invokenestedagent'],
       ['connectionProviders/xmlOperations', 'xmlValidation'],
       ['connectionProviders/xmlOperations', 'xmlTransform'],
       ['connectionProviders/liquidOperations', 'liquidJsonToJson'],
diff --git a/libs/designer-v2/src/lib/common/constants.ts b/libs/designer-v2/src/lib/common/constants.ts
@@ -979,6 +979,7 @@ export default {
     SELECT_BATCH_WORKFLOW_ACTION: 'sendtobatch',
     SELECT_BATCH_WORKFLOW_TRIGGER: 'sendtobatchtrigger',
     SELECT_MANUAL_WORKFLOW_ACTION: 'invokeworkflow',
+    SELECT_NESTED_AGENT_WORKFLOW_ACTION: 'invokenestedagent',
   },
   CHANNELS: {
     INPUT: '-inputchannel-',
diff --git a/libs/designer-v2/src/lib/ui/panel/recommendation/azureResourceSelection.tsx b/libs/designer-v2/src/lib/ui/panel/recommendation/azureResourceSelection.tsx
@@ -64,6 +64,11 @@ export const AzureResourceSelection = (props: AzureResourceSelectionProps) => {
     id: 'DXwS7e',
     description: "Select workflow with 'An HTTP Request' trigger",
   });
+  const nestedAgentWorkflowTitleText = intl.formatMessage({
+    defaultMessage: 'Select workflow with an Agent loop',
+    id: 'QMuDPI',
+    description: 'Select workflow with an Agent loop',
+  });
   const batchWorkflowTitleText = intl.formatMessage({
     defaultMessage: 'Select a Batch Workflow resource',
     id: 'gvDMuq',
@@ -213,6 +218,21 @@ export const AzureResourceSelection = (props: AzureResourceSelectionProps) => {
         break;
       }
 
+      case Constants.AZURE_RESOURCE_ACTION_TYPES.SELECT_NESTED_AGENT_WORKFLOW_ACTION: {
+        setTitleText(nestedAgentWorkflowTitleText);
+        setResourceTypes(['agentWorkflow']);
+        setGetResourcesCallbacks(() => [() => SearchService().getAgentWorkflows?.()]);
+        setSubmitCallback(() => () => {
+          addResourceOperation({
+            name: getResourceName(selectedResources[0]),
+            presetParameterValues: {
+              'host.workflow.id': selectedResources[0].id,
+            },
+          });
+        });
+        break;
+      }
+
       case Constants.AZURE_RESOURCE_ACTION_TYPES.SELECT_BATCH_WORKFLOW_ACTION: {
         setTitleText(batchWorkflowTitleText);
         setResourceTypes(['batchWorkflow', 'trigger']);
@@ -244,6 +264,7 @@ export const AzureResourceSelection = (props: AzureResourceSelectionProps) => {
     swaggerFunctionAppTitleText,
     getOptionsFromPaths,
     manualWorkflowTitleText,
+    nestedAgentWorkflowTitleText,
     operation.id,
     selectedResources,
   ]);
diff --git a/libs/designer/src/lib/common/constants.ts b/libs/designer/src/lib/common/constants.ts
@@ -984,6 +984,7 @@ export default {
     SELECT_BATCH_WORKFLOW_ACTION: 'sendtobatch',
     SELECT_BATCH_WORKFLOW_TRIGGER: 'sendtobatchtrigger',
     SELECT_MANUAL_WORKFLOW_ACTION: 'invokeworkflow',
+    SELECT_NESTED_AGENT_WORKFLOW_ACTION: 'invokenestedagent',
   },
   CHANNELS: {
     INPUT: '-inputchannel-',
diff --git a/libs/designer/src/lib/ui/panel/recommendation/azureResourceSelection.tsx b/libs/designer/src/lib/ui/panel/recommendation/azureResourceSelection.tsx
@@ -62,6 +62,11 @@ export const AzureResourceSelection = (props: AzureResourceSelectionProps) => {
     id: 'DXwS7e',
     description: "Select workflow with 'An HTTP Request' trigger",
   });
+  const nestedAgentWorkflowTitleText = intl.formatMessage({
+    defaultMessage: 'Select workflow with an Agent loop',
+    id: 'QMuDPI',
+    description: 'Select workflow with an Agent loop',
+  });
   const batchWorkflowTitleText = intl.formatMessage({
     defaultMessage: 'Select a Batch Workflow resource',
     id: 'gvDMuq',
@@ -210,6 +215,21 @@ export const AzureResourceSelection = (props: AzureResourceSelectionProps) => {
         break;
       }
 
+      case Constants.AZURE_RESOURCE_ACTION_TYPES.SELECT_NESTED_AGENT_WORKFLOW_ACTION: {
+        setTitleText(nestedAgentWorkflowTitleText);
+        setResourceTypes(['agentWorkflow']);
+        setGetResourcesCallbacks(() => [() => SearchService().getAgentWorkflows?.()]);
+        setSubmitCallback(() => () => {
+          addResourceOperation({
+            name: getResourceName(selectedResources[0]),
+            presetParameterValues: {
+              'host.workflow.id': selectedResources[0].id,
+            },
+          });
+        });
+        break;
+      }
+
       case Constants.AZURE_RESOURCE_ACTION_TYPES.SELECT_BATCH_WORKFLOW_ACTION: {
         setTitleText(batchWorkflowTitleText);
         setResourceTypes(['batchWorkflow', 'trigger']);
@@ -241,6 +261,7 @@ export const AzureResourceSelection = (props: AzureResourceSelectionProps) => {
     swaggerFunctionAppTitleText,
     getOptionsFromPaths,
     manualWorkflowTitleText,
+    nestedAgentWorkflowTitleText,
     operation.id,
     selectedResources,
   ]);
diff --git a/libs/designer/src/lib/ui/panel/recommendation/searchView.tsx b/libs/designer/src/lib/ui/panel/recommendation/searchView.tsx
@@ -125,7 +125,10 @@ export const SearchView: FC<SearchViewProps> = ({
         return false;
       }
 
-      if (equals(type, constants.NODE.TYPE.NESTED_AGENT) && id === 'invokeNestedAgent') {
+      if (equals(type, constants.NODE.TYPE.NESTED_AGENT) && equals(id, 'invokenestedagent')) {
+        if (!isA2AWorkflow) {
+          return false;
+        }
         if (!(isWithinAgenticLoop || isAgentTool)) {
           return false;
         }
diff --git a/libs/logic-apps-shared/src/designer-client-services/lib/__test__/__mocks__/builtInOperationResponse.ts b/libs/logic-apps-shared/src/designer-client-services/lib/__test__/__mocks__/builtInOperationResponse.ts
@@ -1815,6 +1815,27 @@ export const almostAllBuiltInOperations: DiscoveryOperation<DiscoveryResultTypes
       iconUri: 'https://logicappsv2resources.blob.core.windows.net/icons/workflow.svg',
     },
   },
+  {
+    name: 'invokeNestedAgent',
+    id: 'invokenestedagent',
+    type: 'nestedagent',
+    properties: {
+      api: {
+        id: 'connectionProviders/workflow',
+        name: 'connectionProviders/workflow',
+        displayName: 'Azure Logic Apps',
+        iconUri: 'https://logicappsv2resources.blob.core.windows.net/icons/workflow.svg',
+        brandColor: '#59b2d9',
+        description: 'Azure Logic Apps',
+      },
+      summary: 'Choose a Logic Apps workflow',
+      description: 'Send a task to a nested agent workflow in the same region',
+      visibility: 'Important',
+      operationType: 'NestedAgent',
+      brandColor: '#59b2d9',
+      iconUri: 'https://logicappsv2resources.blob.core.windows.net/icons/workflow.svg',
+    },
+  },
   {
     name: 'xmlTransform',
     id: 'xmlTransform',
diff --git a/libs/logic-apps-shared/src/designer-client-services/lib/base/__test__/search.spec.ts b/libs/logic-apps-shared/src/designer-client-services/lib/base/__test__/search.spec.ts
@@ -0,0 +1,203 @@
+import { describe, test, expect, beforeEach, vi } from 'vitest';
+import type { IHttpClient } from '../../httpClient';
+
+// Create a concrete implementation for testing
+class TestSearchService {
+  constructor(private options: any) {}
+
+  private async getWorkflows(filter: string): Promise<any[]> {
+    const { httpClient, apiHubServiceDetails } = this.options;
+    const uri = `/subscriptions/${apiHubServiceDetails.subscriptionId}/providers/Microsoft.Logic/workflows`;
+    const queryParameters = {
+      'api-version': apiHubServiceDetails.apiVersion,
+      $filter: filter,
+    };
+    const response = await httpClient.get({ uri, queryParameters });
+    return response?.value ?? [];
+  }
+
+  public async getAgentWorkflows(): Promise<any[]> {
+    const requestWorkflows = await this.getWorkflows(
+      "contains(Trigger, 'Request') and (properties/integrationServiceEnvironmentResourceId eq null)"
+    );
+    return requestWorkflows.filter((workflow: any) => {
+      const triggers = workflow.properties?.definition?.triggers ?? {};
+      return Object.values(triggers).some((trigger: any) => trigger.kind?.toLowerCase() === 'agent');
+    });
+  }
+}
+
+describe('BaseSearchService', () => {
+  let mockHttpClient: IHttpClient;
+  let searchService: TestSearchService;
+  let mockOptions: any;
+
+  beforeEach(() => {
+    mockHttpClient = {
+      get: vi.fn(),
+      post: vi.fn(),
+      put: vi.fn(),
+      delete: vi.fn(),
+      patch: vi.fn(),
+      dispose: vi.fn(),
+    };
+
+    mockOptions = {
+      httpClient: mockHttpClient,
+      apiHubServiceDetails: {
+        subscriptionId: 'test-subscription',
+        location: 'westus',
+        apiVersion: '2016-06-01',
+      },
+    };
+
+    searchService = new TestSearchService(mockOptions);
+  });
+
+  describe('getAgentWorkflows', () => {
+    test('should return only workflows with Agent triggers', async () => {
+      const mockWorkflows = {
+        value: [
+          {
+            id: '/workflows/agent-workflow',
+            name: 'agent-workflow',
+            properties: {
+              definition: {
+                triggers: {
+                  manual: {
+                    type: 'Request',
+                    kind: 'Agent',
+                  },
+                },
+              },
+            },
+          },
+          {
+            id: '/workflows/regular-workflow',
+            name: 'regular-workflow',
+            properties: {
+              definition: {
+                triggers: {
+                  manual: {
+                    type: 'Request',
+                    kind: 'Http',
+                  },
+                },
+              },
+            },
+          },
+        ],
+      };
+
+      vi.mocked(mockHttpClient.get).mockResolvedValue(mockWorkflows);
+
+      const result = await searchService.getAgentWorkflows();
+
+      expect(result).toHaveLength(1);
+      expect(result[0].name).toBe('agent-workflow');
+    });
+
+    test('should handle case-insensitive Agent kind matching', async () => {
+      const mockWorkflows = {
+        value: [
+          {
+            id: '/workflows/agent-uppercase',
+            name: 'agent-uppercase',
+            properties: {
+              definition: {
+                triggers: {
+                  manual: { type: 'Request', kind: 'AGENT' },
+                },
+              },
+            },
+          },
+          {
+            id: '/workflows/agent-mixedcase',
+            name: 'agent-mixedcase',
+            properties: {
+              definition: {
+                triggers: {
+                  manual: { type: 'Request', kind: 'AgEnT' },
+                },
+              },
+            },
+          },
+        ],
+      };
+
+      vi.mocked(mockHttpClient.get).mockResolvedValue(mockWorkflows);
+
+      const result = await searchService.getAgentWorkflows();
+
+      expect(result).toHaveLength(2);
+    });
+
+    test('should return empty array when no Agent workflows exist', async () => {
+      const mockWorkflows = {
+        value: [
+          {
+            id: '/workflows/regular',
+            name: 'regular',
+            properties: {
+              definition: {
+                triggers: {
+                  manual: { type: 'Request', kind: 'Http' },
+                },
+              },
+            },
+          },
+        ],
+      };
+
+      vi.mocked(mockHttpClient.get).mockResolvedValue(mockWorkflows);
+
+      const result = await searchService.getAgentWorkflows();
+
+      expect(result).toHaveLength(0);
+    });
+
+    test('should handle workflows with no triggers defined', async () => {
+      const mockWorkflows = {
+        value: [
+          {
+            id: '/workflows/no-triggers',
+            name: 'no-triggers',
+            properties: {
+              definition: {},
+            },
+          },
+        ],
+      };
+
+      vi.mocked(mockHttpClient.get).mockResolvedValue(mockWorkflows);
+
+      const result = await searchService.getAgentWorkflows();
+
+      expect(result).toHaveLength(0);
+    });
+
+    test('should handle workflows with undefined kind', async () => {
+      const mockWorkflows = {
+        value: [
+          {
+            id: '/workflows/no-kind',
+            name: 'no-kind',
+            properties: {
+              definition: {
+                triggers: {
+                  manual: { type: 'Request' },
+                },
+              },
+            },
+          },
+        ],
+      };
+
+      vi.mocked(mockHttpClient.get).mockResolvedValue(mockWorkflows);
+
+      const result = await searchService.getAgentWorkflows();
+
+      expect(result).toHaveLength(0);
+    });
+  });
+});
diff --git a/libs/logic-apps-shared/src/designer-client-services/lib/base/search.ts b/libs/logic-apps-shared/src/designer-client-services/lib/base/search.ts
@@ -343,6 +343,14 @@ export abstract class BaseSearchService implements ISearchService {
     return this.getWorkflows(`contains(Trigger, 'Request') and (${ISE_RESOURCE_ID} eq null)`);
   }
 
+  public async getAgentWorkflows(): Promise<ArmResource<DiscoveryWorkflow>[]> {
+    const requestWorkflows = await this.getWorkflows(`contains(Trigger, 'Request') and (${ISE_RESOURCE_ID} eq null)`);
+    return requestWorkflows.filter((workflow: any) => {
+      const triggers = workflow.properties?.definition?.triggers ?? {};
+      return Object.values(triggers).some((trigger: any) => trigger.kind?.toLowerCase() === 'agent');
+    });
+  }
+
   public async getBatchWorkflows(): Promise<ArmResource<DiscoveryWorkflow>[]> {
     return this.getWorkflows(`contains(Trigger, 'Batch') and (${ISE_RESOURCE_ID} eq null)`);
   }
diff --git a/libs/logic-apps-shared/src/designer-client-services/lib/consumption/__tests__/operationmanifest.spec.ts b/libs/logic-apps-shared/src/designer-client-services/lib/consumption/__tests__/operationmanifest.spec.ts
diff --git a/libs/logic-apps-shared/src/designer-client-services/lib/consumption/manifests/invokeNestedAgent.ts b/libs/logic-apps-shared/src/designer-client-services/lib/consumption/manifests/invokeNestedAgent.ts
diff --git a/libs/logic-apps-shared/src/designer-client-services/lib/consumption/operationmanifest.ts b/libs/logic-apps-shared/src/designer-client-services/lib/consumption/operationmanifest.ts
diff --git a/libs/logic-apps-shared/src/designer-client-services/lib/consumption/operations/invokeWorkflow.ts b/libs/logic-apps-shared/src/designer-client-services/lib/consumption/operations/invokeWorkflow.ts
diff --git a/libs/logic-apps-shared/src/designer-client-services/lib/consumption/search.ts b/libs/logic-apps-shared/src/designer-client-services/lib/consumption/search.ts
diff --git a/libs/logic-apps-shared/src/designer-client-services/lib/search.ts b/libs/logic-apps-shared/src/designer-client-services/lib/search.ts

Original file line number	Diff line number	Diff line change
`@@ -125,7 +125,10 @@ export const SearchView: FC<SearchViewProps> = ({`
`125`	`125`	`return false;`
`126`	`126`	`}`
`127`	`127`
`128`		`- if (equals(type, constants.NODE.TYPE.NESTED_AGENT) && id === 'invokeNestedAgent') {`
	`128`	`+ if (equals(type, constants.NODE.TYPE.NESTED_AGENT) && equals(id, 'invokenestedagent')) {`
	`129`	`+ if (!isA2AWorkflow) {`
	`130`	`+ return false;`
	`131`	`+ }`
`129`	`132`	`if (!(isWithinAgenticLoop \|\| isAgentTool)) {`
`130`	`133`	`return false;`
`131`	`134`	`}`