Merge pull request #114 from tsurdilo/removewaitforcompletionforsubflow

Removing waitForCompletion for subflowref

Author: tsurdilo

api/src/main/java/io/serverlessworkflow/api/deserializers/SubFlowRefDeserializer.java

@@ -56,13 +56,8 @@ public SubFlowRef deserialize(JsonParser jp,
 
         if (!node.isObject()) {
             subflowRef.setWorkflowId(node.asText());
-            subflowRef.setWaitForCompletion(true);
             return subflowRef;
         } else {
-            if (node.get("waitForCompletion") != null) {
-                subflowRef.setWaitForCompletion(node.get("waitForCompletion").asBoolean());
-            }
-
             if (node.get("workflowId") != null) {
                 subflowRef.setWorkflowId(node.get("workflowId").asText());
             }

api/src/main/java/io/serverlessworkflow/api/serializers/SubFlowRefSerializer.java

@@ -39,7 +39,6 @@ public void serialize(SubFlowRef subflowRef,
 
         if (subflowRef != null) {
             if ((subflowRef.getWorkflowId() == null || subflowRef.getWorkflowId().isEmpty())
-                    && subflowRef.isWaitForCompletion()
                     && (subflowRef.getVersion() == null || subflowRef.getVersion().isEmpty())) {
                 gen.writeString(subflowRef.getWorkflowId());
             } else {
@@ -49,10 +48,6 @@ public void serialize(SubFlowRef subflowRef,
                     gen.writeStringField("workflowId", subflowRef.getWorkflowId());
                 }
 
-                if (!subflowRef.isWaitForCompletion()) {
-                    gen.writeBooleanField("waitForCompletion", false);
-                }
-
                 if (subflowRef.getVersion() != null && subflowRef.getVersion().length() > 0) {
                     gen.writeStringField("version", subflowRef.getVersion());
                 }

api/src/main/resources/schema/functions/subflowref.json

@@ -2,11 +2,6 @@
   "type": "object",
   "javaType": "io.serverlessworkflow.api.functions.SubFlowRef",
   "properties": {
-    "waitForCompletion": {
-      "type": "boolean",
-      "default": true,
-      "description": "Workflow execution must wait for sub-workflow to finish before continuing"
-    },
     "workflowId": {
       "type": "string",
       "description": "Unique id of the sub-workflow to be invoked"

api/src/test/java/io/serverlessworkflow/api/test/MarkupToWorkflowTest.java

@@ -498,13 +498,11 @@ public void testSubFlowRef(String workflowLocation) {
         assertNotNull(firstAction.getSubFlowRef());
         SubFlowRef firstSubflowRef = firstAction.getSubFlowRef();
         assertEquals("subflowRefReference", firstSubflowRef.getWorkflowId());
-        assertTrue(firstSubflowRef.isWaitForCompletion());
 
         Action secondAction = operationState.getActions().get(1);
         assertNotNull(secondAction.getSubFlowRef());
         SubFlowRef secondSubflowRef = secondAction.getSubFlowRef();
         assertEquals("subflowrefworkflowid", secondSubflowRef.getWorkflowId());
-        assertFalse(secondSubflowRef.isWaitForCompletion());
         assertEquals("1.0", secondSubflowRef.getVersion());
 
     }

api/src/test/resources/features/checkcarvitals.json

@@ -21,8 +21,7 @@
       "actions": [
         {
           "subFlowRef": {
-            "workflowId": "vitalscheck",
-            "waitForCompletion": false
+            "workflowId": "vitalscheck"
           }
         }
       ],

api/src/test/resources/features/checkcarvitals.yml

@@ -15,7 +15,6 @@ states:
     actions:
       - subFlowRef:
           workflowId: vitalscheck
-          waitForCompletion: false
     transition: WaitForCarStopped
   - name: WaitForCarStopped
     type: event

api/src/test/resources/features/subflowref.json

@@ -15,7 +15,6 @@
         {
           "subFlowRef": {
             "workflowId": "subflowrefworkflowid",
-            "waitForCompletion": false,
             "version": "1.0"
           }
         }

api/src/test/resources/features/subflowref.yml

@@ -11,6 +11,5 @@ states:
       - subFlowRef: subflowRefReference
       - subFlowRef:
           workflowId: subflowrefworkflowid
-          waitForCompletion: false
           version: '1.0'
     end: true