File tree Expand file tree Collapse file tree
fluent/spec/src/test/java/io/serverlessworkflow/fluent/spec/dsl Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -305,4 +305,27 @@ void when_dsl_subflow_workflow_task() {
305305 assertThat (run .isAwait ()).isFalse ();
306306 assertThat (run .getReturn ()).isEqualTo (RunTaskConfiguration .ProcessReturnType .NONE );
307307 }
308+
309+ @ Test
310+ void when_dsl_subflow_workflow_task_with_map_input () {
311+ Workflow wf =
312+ WorkflowBuilder .workflow ("parent" , "ns" , "1" )
313+ .tasks (
314+ workflow (
315+ workflow ("child.ns" , "child-flow" , "2.3.4" )
316+ .input (java .util .Map .of ("id" , 7 , "region" , "eu" ))
317+ .input ("extra" , true )
318+ .await (true )
319+ .returnType (RunTaskConfiguration .ProcessReturnType .NONE )))
320+ .build ();
321+
322+ var run = wf .getDo ().get (0 ).getTask ().getRunTask ().getRun ().getRunWorkflow ();
323+ assertThat (run ).isNotNull ();
324+ assertThat (run .getWorkflow ().getInput ().getAdditionalProperties ().get ("id" )).isEqualTo (7 );
325+ assertThat (run .getWorkflow ().getInput ().getAdditionalProperties ().get ("region" ))
326+ .isEqualTo ("eu" );
327+ assertThat (run .getWorkflow ().getInput ().getAdditionalProperties ().get ("extra" )).isEqualTo (true );
328+ assertThat (run .isAwait ()).isTrue ();
329+ assertThat (run .getReturn ()).isEqualTo (RunTaskConfiguration .ProcessReturnType .NONE );
330+ }
308331}
You can’t perform that action at this time.
0 commit comments