File tree Expand file tree Collapse file tree 4 files changed +3
-5
lines changed Expand file tree Collapse file tree 4 files changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -22,7 +22,6 @@ use hyperactor::Context;
22
22
use hyperactor:: Handler ;
23
23
use hyperactor:: Instance ;
24
24
use hyperactor:: Named ;
25
- use hyperactor:: cap:: CanSend ;
26
25
use hyperactor:: forward;
27
26
use hyperactor:: message:: Bind ;
28
27
use hyperactor:: message:: Bindings ;
Original file line number Diff line number Diff line change @@ -20,6 +20,7 @@ use hyperactor_mesh::actor_mesh::ActorSupervisionEvents;
20
20
use hyperactor_mesh:: reference:: ActorMeshRef ;
21
21
use hyperactor_mesh:: shared_cell:: SharedCell ;
22
22
use hyperactor_mesh:: shared_cell:: SharedCellRef ;
23
+ use pyo3:: IntoPyObjectExt ;
23
24
use pyo3:: exceptions:: PyEOFError ;
24
25
use pyo3:: exceptions:: PyException ;
25
26
use pyo3:: exceptions:: PyNotImplementedError ;
@@ -389,7 +390,7 @@ async fn get_next(
389
390
Some ( event) => PyActorSupervisionEvent :: from ( event. clone ( ) ) ,
390
391
} ;
391
392
392
- Ok ( Python :: with_gil ( |py| supervision_event. into_py ( py) ) )
393
+ Python :: with_gil ( |py| supervision_event. into_py_any ( py) )
393
394
}
394
395
395
396
// TODO(albertli): this is temporary remove this when pushing all supervision logic to rust.
Original file line number Diff line number Diff line change @@ -54,7 +54,7 @@ impl Actor for LocalStateBrokerActor {
54
54
impl Handler < LocalStateBrokerMessage > for LocalStateBrokerActor {
55
55
async fn handle (
56
56
& mut self ,
57
- cx : & Context < Self > ,
57
+ _cx : & Context < Self > ,
58
58
message : LocalStateBrokerMessage ,
59
59
) -> anyhow:: Result < ( ) > {
60
60
match message {
Original file line number Diff line number Diff line change 9
9
use std:: hash:: DefaultHasher ;
10
10
use std:: hash:: Hash ;
11
11
use std:: hash:: Hasher ;
12
- use std:: ops:: Deref ;
13
12
use std:: sync:: Arc ;
14
13
15
14
use hyperactor:: Mailbox ;
@@ -36,7 +35,6 @@ use hyperactor::message::Bindings;
36
35
use hyperactor:: message:: Unbind ;
37
36
use hyperactor_mesh:: comm:: multicast:: set_cast_info_on_headers;
38
37
use monarch_types:: PickledPyObject ;
39
- use pyo3:: IntoPyObjectExt ;
40
38
use pyo3:: exceptions:: PyEOFError ;
41
39
use pyo3:: exceptions:: PyRuntimeError ;
42
40
use pyo3:: exceptions:: PyValueError ;
You can’t perform that action at this time.
0 commit comments