anchor.diff:          prepare_internal(AtmWorkflowExecutionId, AtmWorkflowExecutionEnv)
       catch _:Reason ->
           % TODO VFS-7637 use audit log
  -        ?error("FAILED TO PREPARE WORKFLOW ~p DUE TO: ~p", [
  +        ?error("[~p] FAILED TO PREPARE WORKFLOW DUE TO: ~p", [
               AtmWorkflowExecutionId, Reason
           ]),
           error
  
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:         unfreeze_lane_iteration_store(AtmWorkflowExecutionEnv, AtmLaneSchema)
      catch _:Reason ->
          % TODO VFS-7637 use audit log
          ?error("[~p] FAILED TO MARK LANE EXECUTION ~p AS ENDED DUE TO: ~p", [
              AtmWorkflowExecutionId, AtmLaneIndex, Reason
          ])
      end.
  
  
  -spec handle_workflow_execution_execution_ended(
      atm_workflow_execution:id(),
      atm_workflow_execution_env:record()
  ) ->
      ok.
  handle_workflow_execution_execution_ended(AtmWorkflowExecutionId, _AtmWorkflowExecutionEnv) ->
      try
          atm_workflow_execution_session:terminate(AtmWorkflowExecutionId)
      catch _:Reason ->
          % TODO VFS-7637 use audit log
          ?error("[~p] FAILED TO MARK WORKFLOW EXECUTION AS ENDED DUE TO: ~p", [
              AtmWorkflowExecutionId, Reason
          ])
      end.
  
  