anchor.diff:      __FAILING_LAMBDA_DRAFT
   )).
   
  +-define(EXP_ERROR_ATM_MEASUREMENT_DISPATCH_FAILED, ?ERROR_ATM_TASK_RESULT_MAPPING_FAILED(
  +    <<"value">>, ?ERROR_ATM_TASK_RESULT_DISPATCH_FAILED(
  +        ?TARGET_STORE_SCHEMA_ID,
  +        ?ERROR_BAD_DATA(<<"dispatchRules">>, str_utils:format_bin(
  +            "Time series name generator '~s' specified in one of the dispatch rules "
  +            "does not reference any defined time series schema",
  +            [?MISSING_TS_NAME_GENERATOR]
  +        ))
  +    )
  +)).
  +
   
   -record(fail_atm_workflow_execution_test_spec, {
       testcase_id :: term(),
  
positive.code:                 #{
                      <<"description">> => <<"Failed to process item.">>,
                      <<"item">> => Item,
                      <<"reason">> => errors:to_json(?ERROR_ATM_TASK_RESULT_MAPPING_FAILED(
                          <<"value">>, ?ERROR_ATM_TASK_RESULT_DISPATCH_FAILED(
                              ?TARGET_STORE_SCHEMA_ID,
                              ?ERROR_BAD_DATA(<<"dispatchRules">>, str_utils:format_bin(
                                  "Time series name generator '~s' specified in one of the dispatch rules "
                                  "does not reference any defined time series schema",
                                  [?MISSING_TS_NAME_GENERATOR]
                              ))
                          )
                      ))
                  }
              end, ItemBatch)
          end
  
negative.code:     atm_workflow_execution_test_runner:mock_call_ctx()
  ) ->
      atm_workflow_execution_test_runner:exp_state_diff().
  uncorrelated_result_failure_expect_task_execution_ended(AtmMockCallCtx = #atm_mock_call_ctx{
      workflow_execution_exp_state = ExpState,
      call_args = [_AtmWorkflowExecutionId, _AtmWorkflowExecutionEnv, AtmTaskExecutionId]
  }) ->
      {true, case atm_workflow_execution_exp_state_builder:get_task_selector(AtmTaskExecutionId, ExpState) of
          {_, _, ?ATM_TASK1_SCHEMA_ID} ->
              ExpTaskLog = #{
                  <<"description">> => <<"Failed to process uncorrelated task results.">>,
                  <<"reason">> => errors:to_json(?EXP_ERROR_ATM_MEASUREMENT_DISPATCH_FAILED)
              },
              ?assert(lists:member(ExpTaskLog, get_audit_log_contents(
                  AtmTaskExecutionId, AtmMockCallCtx
              ))),
  
              uncorrelated_result_expect_t1_failed(AtmTaskExecutionId, ExpState);
          {_, _, ?ATM_TASK2_SCHEMA_ID} ->
              uncorrelated_result_expect_t2_ended(AtmTaskExecutionId, ExpState);
  