Skip to content

Commit

Permalink
change the way to assert template content
Browse files Browse the repository at this point in the history
Signed-off-by: Jackie Han <[email protected]>
  • Loading branch information
jackiehanyang committed Dec 22, 2023
1 parent cf549b0 commit b2e74e3
Showing 1 changed file with 12 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -24,9 +24,12 @@
import org.opensearch.flowframework.model.WorkflowState;

import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

import static org.opensearch.flowframework.common.CommonValue.CREDENTIAL_FIELD;
import static org.opensearch.flowframework.common.CommonValue.PROVISION_WORKFLOW;
Expand Down Expand Up @@ -196,8 +199,16 @@ public void testCreateAndProvisionAgentFrameworkWorkflow() throws Exception {

// Assert based on the agent-framework template
List<ResourceCreated> resourcesCreated = searchHitWorkflowState.resourcesCreated();
Set<String> expectedStepNames = new HashSet<>();
expectedStepNames.add("root_agent");
expectedStepNames.add("sub_agent");
expectedStepNames.add("openAI_connector");
expectedStepNames.add("gpt-3.5-model");
expectedStepNames.add("deployed-gpt-3.5-model");
Set<String> stepNames = resourcesCreated.stream().map(ResourceCreated::workflowStepId).collect(Collectors.toSet());

assertEquals(5, resourcesCreated.size());
assertEquals("create_connector", resourcesCreated.get(0).workflowStepName());
assertEquals(stepNames, expectedStepNames);
assertNotNull(resourcesCreated.get(0).resourceId());

// Hit Deprovision API
Expand Down

0 comments on commit b2e74e3

Please sign in to comment.