anchor.diff:              {ok, _} -> {ID, ExtendedCtx};
               {error, other_node} -> {ID, other_node}
           end
  -    end, TaskIDs).+    end, TaskIDs).
  +
  +-spec log_error_with_stacktrace(term(), string(), [term()]) -> ok.
  +log_error_with_stacktrace(Stacktrace, Format, Args) ->
  +    ?error(Format ++ "~nStacktrace:~n~p", Args ++ [Stacktrace]).
  
positive.code: -define(DEFAULT_GROUP, <<"main_group">>).
  -define(DEFAULT_ENVIRONMENT_ID, <<"default_executor">>).
  
  %%%===================================================================
  %%% API
  %%%===================================================================
  
negative.code:             {ok, JobDescription} = CallbackModule:to_string(Job),
              JobDescription;
          _ -> 
              str_utils:format_bin("~p", [Job])
      end.
  
  -spec repair_ongoing_tasks(pool(), environment_id()) -> [{id(), ctx() | other_node}].
  