Skip to content

Commit 5e92e8a

Browse files
moonlifacebook-github-bot
authored andcommitted
stop logging duplicate supervision stream closed log (#554)
Summary: Pull Request resolved: #554 When a mesh is stopped, we log the error once and exit the monitoring task. Reviewed By: vidhyav Differential Revision: D78424407 fbshipit-source-id: 56041ba414e104041d1682dbe0a7cb2e88680532
1 parent 7293451 commit 5e92e8a

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

monarch_hyperactor/src/actor_mesh.rs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,12 @@ impl PythonActorMesh {
9999

100100
// Ignore the sender error when there is no receiver, which happens when there
101101
// is no active requests to this mesh.
102-
let _ = user_sender.send(event);
102+
let _ = user_sender.send(event.clone());
103+
104+
if event.is_none() {
105+
// The mesh is stopped, so we can stop the monitor.
106+
break;
107+
}
103108
}
104109
}
105110

0 commit comments

Comments
 (0)