Skip to content

Commit

Permalink
refactor: Rename for clarity
Browse files Browse the repository at this point in the history
  • Loading branch information
morgsmccauley committed Jan 11, 2024
1 parent 762a078 commit d250f1f
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions coordinator/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -72,8 +72,10 @@ async fn synchronise_executors(
}
}

for active_executor in active_executors {
executors_handler.stop(active_executor.executor_id).await?;
for unregistered_executor in active_executors {
executors_handler
.stop(unregistered_executor.executor_id)
.await?;
}

Ok(())
Expand Down Expand Up @@ -141,9 +143,9 @@ async fn synchronise_block_streams(
}
}

for active_block_stream in active_block_streams {
for unregistered_block_stream in active_block_streams {
block_streams_handler
.stop(active_block_stream.stream_id)
.stop(unregistered_block_stream.stream_id)
.await?;
}

Expand Down

0 comments on commit d250f1f

Please sign in to comment.