Skip to main content

chronon_backend_sql_common/row/
pool_key.rs

1//! Run pool key normalization for queue routing.
2
3/// Resolve the Redis / queue pool key for a run (`"general"` when unset).
4pub fn run_pool_key(pool_id: Option<&str>) -> &str {
5    match pool_id {
6        None | Some("general") => "general",
7        Some(other) => other,
8    }
9}
10
11#[cfg(test)]
12mod tests {
13    use super::run_pool_key;
14
15    #[test]
16    fn run_pool_key_defaults_to_general() {
17        assert_eq!(run_pool_key(None), "general");
18        assert_eq!(run_pool_key(Some("general")), "general");
19    }
20
21    #[test]
22    fn run_pool_key_preserves_custom_pool() {
23        assert_eq!(run_pool_key(Some("batch")), "batch");
24    }
25}