refactor: readability

Author: Devdutt Shenoi

src/parseable/mod.rs

@@ -832,23 +832,29 @@ impl Parseable {
     /// Updates schema by merging schemas stored by ingestors when running in Query mode
     pub async fn update_schema_when_distributed(
         &self,
-        tables: &Vec<String>,
+        streams: &Vec<String>,
     ) -> Result<(), EventError> {
         if self.options.mode != Mode::Query {
             return Ok(());
         }
 
-        for table in tables {
-            if let Ok(schemas) = self.storage.get_object_store().fetch_schemas(table).await {
-                let new_schema = Schema::try_merge(schemas)?;
-                // commit schema merges the schema internally and updates the schema in storage.
-                self.storage
-                    .get_object_store()
-                    .commit_schema(table, new_schema.clone())
-                    .await?;
+        for stream_name in streams {
+            let Ok(schemas) = self
+                .storage
+                .get_object_store()
+                .fetch_schemas(stream_name)
+                .await
+            else {
+                continue;
+            };
+            let new_schema = Schema::try_merge(schemas)?;
+            // commit schema merges the schema internally and updates the schema in storage.
+            self.storage
+                .get_object_store()
+                .commit_schema(stream_name, new_schema.clone())
+                .await?;
 
-                self.get_stream(table)?.commit_schema(new_schema)?;
-            }
+            self.get_stream(stream_name)?.commit_schema(new_schema)?;
         }
 
         Ok(())