Skip to content

Commit 82d9cd1

Browse files
dulinrileymeta-codesync[bot]
authored andcommitted
Turn on tokio time features for monarch_tensor_worker::stream tests (#1894)
Summary: Pull Request resolved: #1894 Fixing test breakages like: ``` thread 'worker-stream' panicked at fbcode/monarch/hyperactor/src/clock.rs:293:9: A Tokio 1.x context was found, but timers are disabled. Call `enable_time` on the runtime builder to enable timers. ``` in stream.rs This was caused by a new usage of `tokio::time::timeout` via `RealClock.timeout`. But we use this in many places and i Reviewed By: colin2328 Differential Revision: D87099251 fbshipit-source-id: ff6d1d12f09c41eca250f24c2649ef2a5404df7a
1 parent cc7ccf8 commit 82d9cd1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

monarch_tensor_worker/src/stream.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -560,7 +560,7 @@ impl Actor for StreamActor {
560560
// use `block_in_place` for nested async-to-sync-to-async flows.
561561
let rt = tokio::runtime::Builder::new_multi_thread()
562562
.worker_threads(1)
563-
.enable_io()
563+
.enable_all()
564564
.build()
565565
.unwrap();
566566
let result = rt.block_on(async {

0 commit comments

Comments
 (0)