JoinTask a forkTask internal decisionTask

[ghkdwlgns612]

Hello, I have a question about the decision node join inside the fork node. Below is an example of accessing the Join node through Exclusive Join. It works well.

{
  "createTime": 1676421127567,
  "updateTime": 1677050453051,
  "accessPolicy": {},
  "name": "decision_example",
  "description": "Example workflow that uses decision based on the response",
  "version": 4,
  "tasks": [
    {
      "name": "sink-worker-1",
      "taskReferenceName": "process-h1",
      "inputParameters": {
        "http_request": {
          "uri": "https://datausa.io/api/data?drilldowns=Nation&measures=Population",
          "method": "GET"
        }
      },
      "type": "HTTP",
      "startDelay": 0,
      "optional": false,
      "asyncComplete": false
    },
    {
      "name": "fork-task",
      "taskReferenceName": "fork-task-ref",
      "inputParameters": {},
      "type": "FORK_JOIN",
      "forkTasks": [
        [
          {
            "name": "sink-worker-2",
            "taskReferenceName": "process-h2",
            "inputParameters": {
              "http_request": {
                "uri": "https://datausa.io/api/data?drilldowns=Nation&measures=Population",
                "method": "GET"
              }
            },
            "type": "HTTP",
            "startDelay": 0,
            "optional": false,
            "asyncComplete": false
          },
          {
            "name": "check_month",
            "taskReferenceName": "check_month_ref",
            "inputParameters": {
              "month": "${workflow.input.month}"
            },
            "type": "SWITCH",
            "decisionCases": {
              "H1": [
                {
                  "name": "sink-worker-3",
                  "taskReferenceName": "process-h3",
                  "inputParameters": {
                    "http_request": {
                      "uri": "https://datausa.io/api/data?drilldowns=Nation&measures=Population",
                      "method": "GET"
                    }
                  },
                  "type": "HTTP",
                  "startDelay": 0,
                  "optional": false,
                  "asyncComplete": false
                }
              ],
              "H2": [
                {
                  "name": "sink-worker-5",
                  "taskReferenceName": "process-h5",
                  "inputParameters": {
                    "http_request": {
                      "uri": "https://datausa.io/api/data?drilldowns=Nation&measures=Population",
                      "method": "GET"
                    }
                  },
                  "type": "HTTP",
                  "startDelay": 0,
                  "optional": false,
                  "asyncComplete": false
                }
              ]
            },
            "startDelay": 0,
            "optional": false,
            "asyncComplete": false,
            "evaluatorType": "javascript",
            "expression": "$.month > 6 ? 'H2': 'H1' "
          },
          {
            "name": "exclusive_join",
            "taskReferenceName": "exclusive_join_ref",
            "inputParameters": {},
            "type": "EXCLUSIVE_JOIN",
            "startDelay": 0,
            "joinOn": [
              "process-h3",
              "process-h5"
            ],
            "optional": false,
            "asyncComplete": false
          }
        ],
        [
          {
            "name": "sink-worker-4",
            "taskReferenceName": "process-h4",
            "inputParameters": {
              "http_request": {
                "uri": "https://datausa.io/api/data?drilldowns=Nation&measures=Population",
                "method": "GET"
              }
            },
            "type": "HTTP",
            "startDelay": 0,
            "optional": false,
            "asyncComplete": false
          }
        ]
      ],
      "startDelay": 0,
      "optional": false,
      "asyncComplete": false
    },
    {
      "name": "join-task-2",
      "taskReferenceName": "join-task-2-ref",
      "inputParameters": {},
      "type": "JOIN",
      "startDelay": 0,
      "joinOn": [
        "process-h4",
        "exclusive_join_ref"
      ],
      "optional": false,
      "asyncComplete": false
    }
  ],
  "inputParameters": [],
  "outputParameters": {},
  "schemaVersion": 2,
  "restartable": true,
  "workflowStatusListenerEnabled": false,
  "ownerEmail": "[email protected]",
  "timeoutPolicy": "ALERT_ONLY",
  "timeoutSeconds": 0,
  "variables": {},
  "inputTemplate": {}
}

But I want the workflow to work without ExclusiveJoin. The example below eliminates ExclusiveJoin and add taskReferenceName to the joinOn list.

{
  "createTime": 1676421127567,
  "updateTime": 1677050605005,
  "accessPolicy": {},
  "name": "decision_example",
  "description": "Example workflow that uses decision based on the response",
  "version": 5,
  "tasks": [
    {
      "name": "sink-worker-1",
      "taskReferenceName": "process-h1",
      "inputParameters": {
        "http_request": {
          "uri": "https://datausa.io/api/data?drilldowns=Nation&measures=Population",
          "method": "GET"
        }
      },
      "type": "HTTP",
      "startDelay": 0,
      "optional": false,
      "asyncComplete": false
    },
    {
      "name": "fork-task",
      "taskReferenceName": "fork-task-ref",
      "inputParameters": {},
      "type": "FORK_JOIN",
      "forkTasks": [
        [
          {
            "name": "sink-worker-2",
            "taskReferenceName": "process-h2",
            "inputParameters": {
              "http_request": {
                "uri": "https://datausa.io/api/data?drilldowns=Nation&measures=Population",
                "method": "GET"
              }
            },
            "type": "HTTP",
            "startDelay": 0,
            "optional": false,
            "asyncComplete": false
          },
          {
            "name": "check_month",
            "taskReferenceName": "check_month_ref",
            "inputParameters": {
              "month": "${workflow.input.month}"
            },
            "type": "SWITCH",
            "decisionCases": {
              "H1": [
                {
                  "name": "sink-worker-3",
                  "taskReferenceName": "process-h3",
                  "inputParameters": {
                    "http_request": {
                      "uri": "https://datausa.io/api/data?drilldowns=Nation&measures=Population",
                      "method": "GET"
                    }
                  },
                  "type": "HTTP",
                  "startDelay": 0,
                  "optional": false,
                  "asyncComplete": false
                }
              ],
              "H2": [
                {
                  "name": "sink-worker-5",
                  "taskReferenceName": "process-h5",
                  "inputParameters": {
                    "http_request": {
                      "uri": "https://datausa.io/api/data?drilldowns=Nation&measures=Population",
                      "method": "GET"
                    }
                  },
                  "type": "HTTP",
                  "startDelay": 0,
                  "optional": false,
                  "asyncComplete": false
                }
              ]
            },
            "startDelay": 0,
            "optional": false,
            "asyncComplete": false,
            "evaluatorType": "javascript",
            "expression": "$.month > 6 ? 'H2': 'H1' "
          }
        ],
        [
          {
            "name": "sink-worker-4",
            "taskReferenceName": "process-h4",
            "inputParameters": {
              "http_request": {
                "uri": "https://datausa.io/api/data?drilldowns=Nation&measures=Population",
                "method": "GET"
              }
            },
            "type": "HTTP",
            "startDelay": 0,
            "optional": false,
            "asyncComplete": false
          }
        ]
      ],
      "startDelay": 0,
      "optional": false,
      "asyncComplete": false
    },
    {
      "name": "join-task-2",
      "taskReferenceName": "join-task-2-ref",
      "inputParameters": {},
      "type": "JOIN",
      "startDelay": 0,
      "joinOn": [
        "process-h4",
        "process-h3",
        "process-h5"
      ],
      "optional": false,
      "asyncComplete": false
    }
  ],
  "inputParameters": [],
  "outputParameters": {},
  "schemaVersion": 2,
  "restartable": true,
  "workflowStatusListenerEnabled": false,
  "ownerEmail": "[email protected]",
  "timeoutPolicy": "ALERT_ONLY",
  "timeoutSeconds": 0,
  "variables": {},
  "inputTemplate": {}
}

The result is that the join node is still waiting. Another way was to add Decision taskReferenceName to joinOnList. The results are as follows. The result of the last node does not come out. Is there any way to get the results without ExcludeJoin?

...
  "check_month_ref": {
    "evaluationResult": [
      "H1"
    ]
  }
...