Improve debugging on some error messages

nativelink-scheduler/src/simple_scheduler_state_manager.rs

@@ -511,7 +511,9 @@ where
                             },
                             error: Some(err.clone().merge(make_err!(
                                 Code::Internal,
-                                "Job cancelled because it attempted to execute too many times and failed {}",
+                                "Job cancelled because it attempted to execute too many times {} > {} times {}",
+                                awaited_action.attempts,
+                                self.max_job_retries,
                                 format!("for operation_id: {operation_id}, maybe_worker_id: {maybe_worker_id:?}"),
                             ))),
                             ..ActionResult::default()

nativelink-scheduler/tests/simple_scheduler_test.rs

@@ -2008,8 +2008,8 @@ async fn worker_retries_on_internal_error_and_fails_test() -> Result<(), Error>
         if let ActionStage::Completed(stage) = &mut received_state.stage {
             if let Some(real_err) = &mut stage.error {
                 assert!(
-                    real_err.to_string().contains("Job cancelled because it attempted to execute too many times and failed"),
-                    "{real_err} did not contain 'Job cancelled because it attempted to execute too many times and failed'",
+                    real_err.to_string().contains("Job cancelled because it attempted to execute too many times"),
+                    "{real_err} did not contain 'Job cancelled because it attempted to execute too many times'",
                 );
                 *real_err = err;
             }

nativelink-store/src/ac_utils.rs

@@ -51,13 +51,14 @@ pub async fn get_size_and_decode_digest<T: Message + Default + 'static>(
     store: &impl StoreLike,
     key: impl Into<StoreKey<'_>>,
 ) -> Result<(T, usize), Error> {
+    let key = key.into();
     // Note: For unknown reasons we appear to be hitting:
     // https://github.com/rust-lang/rust/issues/92096
     // or a smiliar issue if we try to use the non-store driver function, so we
     // are using the store driver function here.
     let mut store_data_resp = store
         .as_store_driver_pin()
-        .get_part_unchunked(key.into(), 0, Some(MAX_ACTION_MSG_SIZE))
+        .get_part_unchunked(key.borrow(), 0, Some(MAX_ACTION_MSG_SIZE))
         .await;
     if let Err(err) = &mut store_data_resp {
         if err.code == Code::NotFound {
@@ -74,7 +75,7 @@ pub async fn get_size_and_decode_digest<T: Message + Default + 'static>(
         .err_tip_with_code(|e| {
             (
                 Code::NotFound,
-                format!("Stored value appears to be corrupt: {e}"),
+                format!("Stored value appears to be corrupt: {e} - {key:?}"),
             )
         })
         .map(|v| (v, store_data_len))

nativelink-util/src/action_messages.rs

@@ -213,6 +213,8 @@ impl std::fmt::Display for ActionUniqueQualifier {
             Self::Uncachable(action) => (false, action),
         };
         f.write_fmt(format_args!(
+            // Note: We use underscores because it makes escaping easier
+            // for redis.
             "{}/{}/{}-{}/{}",
             unique_key.instance_name,
             unique_key.digest_function,