File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -572,7 +572,7 @@ impl WorkerRef {
572
572
let bytes = match worker. poll_nexus_task ( ) . await {
573
573
Ok ( task) => task. encode_to_vec ( ) ,
574
574
Err ( PollError :: ShutDown ) => return Err ( PollShutdownError :: new_err ( ( ) ) ) ,
575
- Err ( err) => return Err ( PyRuntimeError :: new_err ( format ! ( "Poll failure: {}" , err ) ) ) ,
575
+ Err ( err) => return Err ( PyRuntimeError :: new_err ( format ! ( "Poll failure: {err}" ) ) ) ,
576
576
} ;
577
577
Ok ( bytes)
578
578
} )
@@ -618,7 +618,7 @@ impl WorkerRef {
618
618
) -> PyResult < Bound < ' p , PyAny > > {
619
619
let worker = self . worker . as_ref ( ) . unwrap ( ) . clone ( ) ;
620
620
let completion = NexusTaskCompletion :: decode ( proto. as_bytes ( ) )
621
- . map_err ( |err| PyValueError :: new_err ( format ! ( "Invalid proto: {}" , err ) ) ) ?;
621
+ . map_err ( |err| PyValueError :: new_err ( format ! ( "Invalid proto: {err}" ) ) ) ?;
622
622
self . runtime . future_into_py ( py, async move {
623
623
worker
624
624
. complete_nexus_task ( completion)
You can’t perform that action at this time.
0 commit comments