Skip to content

Commit 291b76c

Browse files
committed
persist: add multi_thread to test_shard_source_*_initial_as_of tests
Looks like with the Tasked commit, these end up in some sort of hang if there's only one tokio thread.
1 parent 83c2f78 commit 291b76c

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

src/persist-client/src/operators/shard_source.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -638,7 +638,7 @@ mod tests {
638638
///
639639
/// NOTE: This test is weird: if everything is good it will pass. If we
640640
/// break the assumption that we test this will time out and we will notice.
641-
#[mz_ore::test(tokio::test)]
641+
#[mz_ore::test(tokio::test(flavor = "multi_thread"))]
642642
#[cfg_attr(miri, ignore)] // unsupported operation: returning ready events from epoll_wait is not yet implemented
643643
async fn test_shard_source_implicit_initial_as_of() {
644644
let (persist_clients, location) = new_test_client_cache_and_location();
@@ -707,7 +707,7 @@ mod tests {
707707
///
708708
/// NOTE: This test is weird: if everything is good it will pass. If we
709709
/// break the assumption that we test this will time out and we will notice.
710-
#[mz_ore::test(tokio::test)]
710+
#[mz_ore::test(tokio::test(flavor = "multi_thread"))]
711711
#[cfg_attr(miri, ignore)] // unsupported operation: returning ready events from epoll_wait is not yet implemented
712712
async fn test_shard_source_explicit_initial_as_of() {
713713
let (persist_clients, location) = new_test_client_cache_and_location();

0 commit comments

Comments
 (0)