Ensure that input/output are correctly represented in transfer objects

core/src/main/java/com/netflix/conductor/model/TaskModel.java

@@ -529,7 +529,7 @@ public long getQueueWaitTime() {
         return 0L;
     }
 
-    /** @return a deep copy of the task instance */
+    /** @return a copy of the task instance */
     public TaskModel copy() {
         TaskModel copy = new TaskModel();
         BeanUtils.copyProperties(this, copy);
@@ -760,6 +760,14 @@ public Task toTask() {
         Task task = new Task();
         BeanUtils.copyProperties(this, task);
         task.setStatus(Task.Status.valueOf(status.name()));
+
+        // ensure that input/output is properly represented
+        if (externalInputPayloadStoragePath != null) {
+            task.setInputData(new HashMap<>());
+        }
+        if (externalOutputPayloadStoragePath != null) {
+            task.setOutputData(new HashMap<>());
+        }
         return task;
     }
 

core/src/main/java/com/netflix/conductor/model/WorkflowModel.java

@@ -420,13 +420,6 @@ public void internalizeOutput(Map<String, Object> data) {
         this.outputPayload = data;
     }
 
-    /** @return a copy of the workflow instance */
-    public WorkflowModel copy() {
-        WorkflowModel copy = new WorkflowModel();
-        BeanUtils.copyProperties(this, copy);
-        return copy;
-    }
-
     @Override
     public String toString() {
         String name = workflowDefinition != null ? workflowDefinition.getName() : null;
@@ -505,6 +498,14 @@ public Workflow toWorkflow() {
         BeanUtils.copyProperties(this, workflow);
         workflow.setStatus(Workflow.WorkflowStatus.valueOf(this.status.name()));
         workflow.setTasks(tasks.stream().map(TaskModel::toTask).collect(Collectors.toList()));
+
+        // ensure that input/output is properly represented
+        if (externalInputPayloadStoragePath != null) {
+            workflow.setInput(new HashMap<>());
+        }
+        if (externalOutputPayloadStoragePath != null) {
+            workflow.setOutput(new HashMap<>());
+        }
         return workflow;
     }
 }