Fix redis query in search_by_index_prefix.

Author: dkostyrev

nativelink-scheduler/tests/redis_store_awaited_action_db_test.rs

@@ -216,19 +216,26 @@ impl Mocks for FakeRedisBackend {
         }
 
         if actual.cmd == Str::from_static("FT.AGGREGATE") {
-            // The query is @field:value where value might be wrapped in braces.
+            // The query is @field:value where value might be wrapped in braces or *.
             let query = actual.args[1]
                 .clone()
                 .into_string()
                 .expect("Aggregate query should be a string");
-            assert_eq!(&query[..1], "@");
-            let mut parts = query[1..].split(':');
-            let field = parts.next().expect("No field name");
-            let value = parts.next().expect("No value");
-            let value = value
-                .strip_prefix("{ ")
-                .and_then(|s| s.strip_suffix(" }"))
-                .unwrap_or(value);
+
+            let (field, value) = if query.as_str() == "*" {
+                ("", query.as_str())
+            } else {
+                assert_eq!(&query[..1], "@");
+                let mut parts = query[1..].split(':');
+                let field = parts.next().expect("No field name");
+                let value = parts.next().expect("No value");
+                let value = value
+                    .strip_prefix("{ ")
+                    .and_then(|s| s.strip_suffix(" }"))
+                    .unwrap_or(value);
+
+                (field, value)
+            };
             // Lazy implementation making assumptions.
             assert_eq!(
                 actual.args[2..6],

nativelink-store/src/redis_store.rs

@@ -1168,7 +1168,10 @@ impl SchedulerStore for RedisStore {
                         "{}",
                         get_index_name!(K::KEY_PREFIX, K::INDEX_NAME, K::MAYBE_SORT_KEY)
                     ),
-                    format!("@{}:{{ {} }}", K::INDEX_NAME, sanitized_field),
+                    match sanitized_field.is_empty() {
+                        true => String::from("*"),
+                        false => format!("@{}:{{ {} }}", K::INDEX_NAME, sanitized_field),
+                    },
                     FtAggregateOptions {
                         load: Some(Load::Some(vec![
                             SearchField {