anchor.diff:  -export([
       prepare/2,
       get_lane_spec/3,
  +
       process_item/6,
       process_result/4,
  +
       handle_task_execution_ended/3,
  -    handle_lane_execution_ended/3
  +    handle_lane_execution_ended/3,
  +    handle_workflow_execution_execution_ended/2
   ]).
   
   
  
positive.code:     atm_task_execution:id()
  ) ->
      ok.
  handle_task_execution_ended(_AtmWorkflowExecutionId, _AtmWorkflowExecutionEnv, AtmTaskExecutionId) ->
      try
          ok = atm_task_execution_api:mark_ended(AtmTaskExecutionId)
      catch _:Reason ->
          % TODO VFS-7637 use audit log
          ?error("FAILED TO MARK TASK EXECUTION ~p AS ENDED DUE TO: ~p", [
              AtmTaskExecutionId, Reason
          ])
      end.
  
  
negative.code:         prepare_internal(AtmWorkflowExecutionId, AtmWorkflowExecutionEnv)
      catch _:Reason ->
          % TODO VFS-7637 use audit log
          ?error("[~p] FAILED TO PREPARE WORKFLOW DUE TO: ~p", [
              AtmWorkflowExecutionId, Reason
          ]),
          error
  