Default test

engine_test.go

@@ -217,6 +217,45 @@ outputs:
 	assert.Equals(t, outputData.(map[any]any), map[any]any{"message": "Hello, Arca Lot!"})
 }
 
+func TestE2EWorkflowDefaultInput(t *testing.T) {
+	content := map[string][]byte{
+		"workflow.yaml": []byte(`version: v0.2.0
+input:
+  root: RootObject
+  objects:
+    RootObject:
+      id: RootObject
+      properties:
+        name:
+          type:
+            type_id: string
+          default: not
+          required: false
+steps:
+  example:
+    plugin: 
+      src: quay.io/arcalot/arcaflow-plugin-template-python:0.2.1
+      deployment_type: image
+    step: hello-world
+    input:
+      name: !expr $.input.name
+outputs:
+  success:
+    message: !expr $.steps.example.outputs.success.message`),
+	}
+	fileCache := loadfile.NewFileCache("", content)
+	outputID, outputData, outputError, err := createTestEngine(t).RunWorkflow(
+		context.Background(),
+		[]byte(`{}`),
+		fileCache,
+		"",
+	)
+	assert.NoError(t, err)
+	assert.Equals(t, outputError, false)
+	assert.Equals(t, outputID, "success")
+	assert.Equals(t, outputData.(map[any]any), map[any]any{"message": "Hello, not!"})
+}
+
 // Test_CacheSubworkflows tests that every sub-workflow filename
 // referenced in the main workflow is incorporated into the
 // workflow's execution.

workflow/workflow.go

@@ -58,10 +58,11 @@ func (e *executableWorkflow) DAG() dgraph.DirectedGraph[*DAGItem] {
 func (e *executableWorkflow) Execute(ctx context.Context, serializedInput any) (outputID string, outputData any, err error) { //nolint:gocognit
 	// First, we unserialize the input. This makes sure we didn't get garbage data.
 
-	_, err = e.input.Unserialize(serializedInput)
+	unserializedInput, err := e.input.Unserialize(serializedInput)
 	if err != nil {
 		return "", nil, fmt.Errorf("invalid workflow input (%w)", err)
 	}
+	reSerializedInput, err := e.input.Serialize(unserializedInput)
 
 	// We use an internal cancel function to abort the workflow if something bad happens.
 	ctx, cancel := context.WithCancel(ctx)
@@ -72,7 +73,7 @@ func (e *executableWorkflow) Execute(ctx context.Context, serializedInput any) (
 		config: e.config,
 		lock:   &sync.Mutex{},
 		data: map[string]any{
-			WorkflowInputKey: serializedInput,
+			WorkflowInputKey: reSerializedInput,
 			WorkflowStepsKey: map[string]any{},
 		},
 		dag:               e.dag.Clone(),