Skip to content

Commit 2e9725e

Browse files
committed
core: Simplify handle_assignment_event
1 parent b133b2d commit 2e9725e

File tree

1 file changed

+4
-13
lines changed

1 file changed

+4
-13
lines changed

core/src/subgraph/registrar.rs

Lines changed: 4 additions & 13 deletions
Original file line numberDiff line numberDiff 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
462459
async 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

0 commit comments

Comments
 (0)