Skip to content

Commit 576e40d

Browse files
committed
Fix get_all_awaited_actions redis query.
1 parent 92869d9 commit 576e40d

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

nativelink-scheduler/src/store_awaited_action_db.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -820,7 +820,7 @@ where
820820
) -> Result<impl Stream<Item = Result<Self::Subscriber, Error>>, Error> {
821821
Ok(self
822822
.store
823-
.search_by_index_prefix(SearchStateToAwaitedAction(""))
823+
.search_by_index_prefix(SearchStateToAwaitedAction("queued|cache_check|executing"))
824824
.await
825825
.err_tip(|| "In RedisAwaitedActionDb::get_range_of_actions")?
826826
.map_ok(move |awaited_action| {

nativelink-store/src/redis_store.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -966,7 +966,7 @@ const fn try_sanitize(s: &str) -> Option<&str> {
966966
break;
967967
}
968968
let c = chars[i];
969-
if !c.is_ascii_alphanumeric() && c != b'_' {
969+
if !c.is_ascii_alphanumeric() && c != b'_' && c != b'|' {
970970
return None;
971971
}
972972
i += 1;

0 commit comments

Comments
 (0)