File tree Expand file tree Collapse file tree 1 file changed +4
-13
lines changed Expand file tree Collapse file tree 1 file changed +4
-13
lines changed Original file line number Diff line number Diff line change @@ -130,15 +130,12 @@ where
130130 let this = self . cheap_clone ( ) ;
131131 let provider = self . provider . clone ( ) ;
132132 async move {
133- if let Err ( e ) = match event {
133+ match event {
134134 Ok ( event) => {
135135 assert_eq ! ( event. node_id( ) , & this. node_id) ;
136- handle_assignment_event ( event, provider. clone ( ) , & this. logger )
137- . await
136+ handle_assignment_event ( event, provider. clone ( ) ) . await
138137 }
139- Err ( e) => Err ( e) ,
140- } {
141- panic_on_cancel ( & this. logger , e) ;
138+ Err ( e) => panic_on_cancel ( & this. logger , e) ,
142139 } ;
143140 }
144141 }
@@ -462,12 +459,7 @@ where
462459async fn handle_assignment_event (
463460 event : AssignmentEvent ,
464461 provider : Arc < impl SubgraphAssignmentProviderTrait > ,
465- logger : & Logger ,
466- ) -> Result < ( ) , CancelableError < SubgraphAssignmentProviderError > > {
467- let logger = logger. clone ( ) ;
468-
469- debug ! ( logger, "Received assignment event: {:?}" , event) ;
470-
462+ ) {
471463 match event {
472464 AssignmentEvent :: Add {
473465 deployment,
@@ -478,7 +470,6 @@ async fn handle_assignment_event(
478470 node_id : _,
479471 } => provider. stop ( deployment) . await ,
480472 }
481- Ok ( ( ) )
482473}
483474
484475/// Resolves the subgraph's earliest block
You can’t perform that action at this time.
0 commit comments