#512

Author: paxtonhare

marklogic-data-hub/src/main/java/com/marklogic/hub/deploy/commands/LoadUserModulesCommand.java

@@ -174,7 +174,9 @@ public void execute(CommandContext context) {
                     handle.setFormat(Format.XML);
                     documentWriteSet.add(flow.getFlowDbPath(), handle);
                 }
-                documentManager.write(documentWriteSet);
+                if (documentWriteSet.size() > 0) {
+                    documentManager.write(documentWriteSet);
+                }
 
                 Files.walkFileTree(startPath, new SimpleFileVisitor<Path>() {
                     @Override

marklogic-data-hub/src/test/java/com/marklogic/hub/EndToEndFlowTests.java

@@ -146,6 +146,10 @@ public static void setup() throws IOException, InterruptedException, ParserConfi
             createLegacyFlow("legacy", codeFormat, dataFormat, flowType);
         });
 
+        allCombos((codeFormat, dataFormat, flowType) -> {
+            createFlow("has a space ", codeFormat, dataFormat, flowType, null);
+        });
+
         flowManager = new FlowManager(getHubConfig());
         List<String> legacyFlows = flowManager.getLegacyFlows();
         assertEquals(8, legacyFlows.size(), String.join("\n", legacyFlows));
@@ -214,6 +218,30 @@ public List<DynamicTest> generateTests() throws InterruptedException, ParserConf
         });
 
 
+        allCombos((codeFormat, dataFormat, flowType) -> {
+            String prefix = "has a space ";
+            String flowName = getFlowName(prefix, codeFormat, dataFormat, flowType);
+            if (flowType.equals(FlowType.INPUT)) {
+                tests.add(DynamicTest.dynamicTest(flowName + " MLCP", () -> {
+                    Map<String, Object> options = new HashMap<>();
+                    FinalCounts finalCounts = new FinalCounts(1, 0, 2, 1, 0, 0, 1, 0, 0, 0, "FINISHED");
+                    testInputFlowViaMlcp(prefix, "", stagingClient, codeFormat, dataFormat, options, finalCounts);
+                }));
+                tests.add(DynamicTest.dynamicTest(flowName + " REST", () -> {
+                    Map<String, Object> options = new HashMap<>();
+                    FinalCounts finalCounts = new FinalCounts(1, 0, 2, 0, 0, 0, 0, 0, 0, 0, "FINISHED");
+                    testInputFlowViaREST(prefix, "", codeFormat, dataFormat, options, finalCounts);
+                }));
+            }
+            else {
+                Map<String, Object> options = new HashMap<>();
+                tests.add(DynamicTest.dynamicTest(flowName + " wait", () -> {
+                    FinalCounts finalCounts = new FinalCounts(TEST_SIZE, TEST_SIZE + 1, TEST_SIZE + 1, 1, TEST_SIZE, 0, TEST_SIZE, 0, TEST_SIZE/BATCH_SIZE, 0, "FINISHED");
+                    testHarmonizeFlow(prefix, codeFormat, dataFormat, options, stagingClient, HubConfig.DEFAULT_FINAL_NAME, finalCounts, true);
+                }));
+            }
+        });
+
         allCombos((codeFormat, dataFormat, flowType) -> {
             String prefix = "1x-legacy";
             String flowName = getFlowName(prefix, codeFormat, dataFormat, flowType);