From fbae4282df226a46842ab8c72ca5b6f09d949ac0 Mon Sep 17 00:00:00 2001
From: "Carol (Nichols || Goulding)" <carol.nichols@gmail.com>
Date: Fri, 19 Aug 2022 15:17:02 -0400
Subject: [PATCH] fix: Rename another sequencer to shard to be hopefully
 clearer

---
 ingester/src/handler.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/ingester/src/handler.rs b/ingester/src/handler.rs
index 8d4189db1d..28d283de19 100644
--- a/ingester/src/handler.rs
+++ b/ingester/src/handler.rs
@@ -134,7 +134,7 @@ impl IngestHandlerImpl {
     pub async fn new(
         lifecycle_config: LifecycleConfig,
         topic: KafkaTopic,
-        sequencer_states: BTreeMap<KafkaPartition, Shard>, // XXXJPG
+        shard_states: BTreeMap<KafkaPartition, Shard>,
         catalog: Arc<dyn Catalog>,
         object_store: Arc<DynObjectStore>,
         write_buffer: Arc<dyn WriteBufferReading>,
@@ -145,7 +145,7 @@ impl IngestHandlerImpl {
     ) -> Result<Self> {
         // build the initial ingester data state
         let mut shards = BTreeMap::new();
-        for s in sequencer_states.values() {
+        for s in shard_states.values() {
             shards.insert(
                 s.id,
                 ShardData::new(s.kafka_partition, Arc::clone(&metric_registry)),
@@ -183,10 +183,10 @@ impl IngestHandlerImpl {
             lifecycle_config
         );
 
-        let mut join_handles = Vec::with_capacity(sequencer_states.len() + 1);
+        let mut join_handles = Vec::with_capacity(shard_states.len() + 1);
         join_handles.push(("lifecycle manager".to_owned(), shared_handle(handle)));
 
-        for (kafka_partition, shard) in sequencer_states {
+        for (kafka_partition, shard) in shard_states {
             let metric_registry = Arc::clone(&metric_registry);
 
             // Acquire a write buffer stream and seek it to the last