File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -463,11 +463,11 @@ mod tests {
463463 use std:: time:: Duration ;
464464
465465 let dir = tempfile:: tempdir ( ) . unwrap ( ) ;
466- let agent_dir = dir. path ( ) ;
466+ let agent_dir = dir. path ( ) . join ( "agents/h/worker" ) ;
467467 std:: fs:: create_dir_all ( agent_dir. join ( "resources/inbox" ) ) . unwrap ( ) ;
468468
469469 let ( tx, rx) = channel ( ) ;
470- let _watcher = watch_delivery_inputs ( agent_dir, tx) . expect ( "start inotify watcher" ) ;
470+ let _watcher = watch_delivery_inputs ( & agent_dir, tx) . expect ( "start inotify watcher" ) ;
471471
472472 // Runtime records the pump's own process group writes must stay silent: the observed
473473 // harness state and the harness context beside it, their locks and atomic temp siblings,
@@ -481,7 +481,7 @@ mod tests {
481481 std:: fs:: write ( agent_dir. join ( "resources/streams/s/state.json" ) , "{}" ) . unwrap ( ) ;
482482 // …and a real harness-context write through its own writer, staging outside the agent
483483 // subtree and renaming the record in, which is the shape a producer actually produces.
484- st2_harness_context_write ( agent_dir) ;
484+ st2_harness_context_write ( & agent_dir) ;
485485 assert ! (
486486 rx. recv_timeout( Duration :: from_millis( 200 ) ) . is_err( ) ,
487487 "runtime-record writes must not wake the delivery pump"
You can’t perform that action at this time.
0 commit comments