@SuppressWarnings("unchecked")
    public Map<String, Object> curateDynamicForkLargePayload() {
        Map<String, Object> dynamicForkLargePayload = new HashMap<>();
        try {
            InputStream inputStream = readOutputDotJson();
            Map<String, Object> largePayload = objectMapper.readValue(inputStream, Map.class);

            WorkflowTask simpleWorkflowTask = new WorkflowTask();
            simpleWorkflowTask.setName("integration_task_10");
            simpleWorkflowTask.setTaskReferenceName("t10");
            simpleWorkflowTask.setType(TASK_TYPE_SIMPLE);
            simpleWorkflowTask.setInputParameters(
                    Collections.singletonMap("p1", "${workflow.input.imageType}"));

            WorkflowDef subWorkflowDef = new WorkflowDef();
            subWorkflowDef.setName("one_task_workflow");
            subWorkflowDef.setVersion(1);
            subWorkflowDef.setTasks(Collections.singletonList(simpleWorkflowTask));

            SubWorkflowParams subWorkflowParams = new SubWorkflowParams();
            subWorkflowParams.setName("one_task_workflow");
            subWorkflowParams.setVersion(1);
            subWorkflowParams.setWorkflowDef(subWorkflowDef);

            WorkflowTask subWorkflowTask = new WorkflowTask();
            subWorkflowTask.setName("large_payload_subworkflow");
            subWorkflowTask.setType(TASK_TYPE_SUB_WORKFLOW);
            subWorkflowTask.setTaskReferenceName("large_payload_subworkflow");
            subWorkflowTask.setInputParameters(largePayload);
            subWorkflowTask.setSubWorkflowParam(subWorkflowParams);

            dynamicForkLargePayload.put("dynamicTasks", List.of(subWorkflowTask));
            dynamicForkLargePayload.put(
                    "dynamicTasksInput", Map.of("large_payload_subworkflow", largePayload));
        } catch (IOException e) {
            // just handle this exception here and return empty map so that test will fail in case
            // this exception is thrown
        }
        return dynamicForkLargePayload;
    }
A {@link ExternalPayloadStorage} implementation that stores payload in file.
test-harness/src/test/java/com/netflix/conductor/test/utils/MockExternalPayloadStorage.java