anchor.diff:                  parallel_boxes = [
                       #atm_parallel_box_schema_draft{
                           id = <<"pb3">>,
  -                        tasks = [?ECHO_ATM_TASK_SCHEMA_DRAFT(<<"task4">>, <<"st_devnull">>)]
  +                        tasks = [?ECHO_ATM_TASK_SCHEMA_DRAFT(<<"task4">>, <<"task4_dst_store">>)]
                       }
                   ],
  -                store_iterator_spec = #atm_store_iterator_spec_draft{store_schema_id = <<"st_4">>},
  +                store_iterator_spec = #atm_store_iterator_spec_draft{store_schema_id = <<"iterated_store">>},
                   max_retries = ?RAND_INT(3, 6)
               }
           ]
  
positive.code:                     },
                      handle_lane_execution_stopped = #atm_step_mock_spec{after_step_exp_state_diff = no_diff}
                  },
                  #atm_lane_run_execution_test_spec{
                      selector = {2, 1},
                      prepare_lane = #atm_step_mock_spec{
                          defer_after = {prepare_lane, after_step, {1, 1}},
                          after_step_exp_state_diff = no_diff
                      }
                  }
              ],
              handle_workflow_execution_stopped = #atm_step_mock_spec{
                  after_step_exp_state_diff = [
  
negative.code:                         % - task3 transitions to 'cancelled' as definitely no item was scheduled for it.
                          before_step_hook = fun atm_workflow_execution_test_utils:cancel_workflow_execution/1,
                          before_step_exp_state_diff = [
                              {all_tasks, {1, 1}, stopping_due_to, cancel},  %% TODO VFS-9917 expectation per task ?
                              {lane_run, {1, 1}, stopping},
                              workflow_stopping
                          ]
                      },
                      handle_task_execution_stopped = #atm_step_mock_spec{
                          % Assert not all items were processed by tasks
                          before_step_hook = fun(AtmMockCallCtx = #atm_mock_call_ctx{
                              workflow_execution_exp_state = ExpState,
                              call_args = [_AtmWorkflowExecutionId, _AtmWorkflowExecutionEnv, AtmTaskExecutionId]
                          }) ->
                              {_, _, ExpItemsProcessed} = atm_workflow_execution_exp_state_builder:get_task_stats(
                                  AtmTaskExecutionId, ExpState
                              ),
                              ?assert(ExpItemsProcessed < ItemCount),
  
                              AtmTaskSchemaId = atm_workflow_execution_exp_state_builder:get_task_schema_id(
                                  AtmTaskExecutionId, ExpState
                              ),
                              #{<<"items">> := StDstItems} = atm_workflow_execution_test_utils:browse_store(
                                  <<AtmTaskSchemaId/binary, "_dst_store">>, AtmMockCallCtx
                              ),
                              ?assertEqual(ExpItemsProcessed, length(StDstItems))
                          end,
  