anchor.diff:  -define(WAITING_FOR_NEXT_LANE_PREPARATION_END(HasExceptionAppeared), #execution_cancelled{
       execution_step = waiting_on_next_lane_prepare, call_count = 0, has_exception_appeared = HasExceptionAppeared}).
   -define(EXECUTION_ENDED_AFTER_CANCEL(HasExceptionAppeared, ProgressDataPersistence), #execution_cancelled{
  -    execution_step = finishing_execution, call_count = 0,
  +    execution_step = finishing_execution, call_count = 0, callbacks_to_execute = [],
       has_exception_appeared = HasExceptionAppeared, expected_progress_data_persistence = ProgressDataPersistence}).
   
   
  
positive.code:             NextIterationStep = get_next_iterator(Handler, LaneExecutionContext, Iterator, ExecutionId),
              FailureCountToCancel = maps:get(failure_count_to_cancel, LaneSpec, undefined),
              case update(ExecutionId, fun(State) ->
                  finish_lane_preparation_internal(State, BoxesMap, LaneExecutionContext, NextIterationStep, FailureCountToCancel)
              end) of
                  {ok, #document{value = #workflow_execution_state{
                      execution_status = ?EXECUTION_CANCELLED(_), current_lane = CurrentLane,
  
negative.code:     ok.
  
  
  -spec reset_state_fields_for_next_lane(state()) -> state().
  reset_state_fields_for_next_lane(State) ->
      State#workflow_execution_state{
          iteration_state = workflow_iteration_state:init(),
          jobs = workflow_jobs:init(),
          tasks_data_registry = workflow_tasks_data_registry:empty()
      }.
  
  
  -spec handle_lane_preparation_failure(state(), workflow_engine:lane_id() | undefined,
      workflow_engine:preparation_mode()) -> {ok, state()} | ?WF_ERROR_UNKNOWN_LANE.
  handle_lane_preparation_failure(
  