formatting, remove unneded logs

Signed-off-by: Allen Samuels <[email protected]>

Author: allenss-amazon

integration/indexes.py

@@ -217,4 +217,4 @@ def query(self, client:valkey.client, query_string: str, *args) -> dict[bytes, d
             print("Key", key, "Fields:", fields, " Values:", values)
             dict_result[key] = {fields[i]:values[i] for i in range(len(fields))}
         print("Final result", dict_result)
-        return dict_result
+        return dict_result

integration/test_dbnum.py

@@ -7,7 +7,7 @@
 import pytest, time, logging
 from indexes import *
 
-class TestFanoutBase(ValkeySearchClusterTestCaseDebugMode):
+class TestDBNum(ValkeySearchClusterTestCaseDebugMode):
     def setup_connections(self):
         self.client00 = self.get_primary(0).connect();
         self.client00.select(0)

src/coordinator/metadata_manager.cc

@@ -354,7 +354,7 @@ void MetadataManager::HandleBroadcastedMetadata(
                           schema = std::unique_ptr<GlobalMetadata>(
                               response.release_metadata()),
                           address = std::move(address)] {
-          VMSDK_LOG_EVERY_N(WARNING, ctx, 1)
+          VMSDK_LOG_EVERY_N_SEC(DEBUG, ctx, 1)
               << "Got GlobalMetadata from " << address << ": "
               << schema->DebugString();
           auto &metadata_manager = MetadataManager::Instance();
@@ -364,7 +364,7 @@ void MetadataManager::HandleBroadcastedMetadata(
                 << "Failed to reconcile schemas: " << status.message();
             return;
           }
-          VMSDK_LOG_EVERY_N(WARNING, ctx, 1)
+          VMSDK_LOG_EVERY_N_SEC(DEBUG, ctx, 1)
               << "Successfully reconciled schemas! New GlobalMetadata: "
               << metadata_manager.GetGlobalMetadata()->DebugString();
         });

src/coordinator/server.cc

@@ -188,16 +188,12 @@ grpc::ServerUnaryReactor* Service::SearchIndexPartition(
 std::pair<grpc::Status, coordinator::InfoIndexPartitionResponse>
 Service::GenerateInfoResponse(
     const coordinator::InfoIndexPartitionRequest& request) {
-  VMSDK_LOG(WARNING, nullptr)
-      << "DELETE: INFO REQUEST " << request.ShortDebugString();
   uint32_t db_num = request.db_num();
   std::string index_name = request.index_name();
   coordinator::InfoIndexPartitionResponse response;
   auto status_or_schema =
       SchemaManager::Instance().GetIndexSchema(db_num, index_name);
   if (!status_or_schema.ok()) {
-    VMSDK_LOG(WARNING, nullptr)
-        << "DELETE: NOT_FOUND: " << status_or_schema.status().ToString();
     response.set_exists(false);
     response.set_index_name(index_name);
     response.set_error(status_or_schema.status().ToString());
@@ -244,8 +240,6 @@ Service::GenerateInfoResponse(
     *response.mutable_index_fingerprint_version() =
         std::move(index_fingerprint_version.value());
   }
-  VMSDK_LOG(WARNING, nullptr)
-      << "DELETE: Found index: " << response.ShortDebugString();
   return std::make_pair(grpc::Status::OK, response);
 }
 

src/schema_manager.cc

@@ -148,7 +148,6 @@ absl::Status GenerateIndexAlreadyExistsError(absl::string_view name) {
 
 absl::StatusOr<std::shared_ptr<IndexSchema>> SchemaManager::LookupInternal(
     uint32_t db_num, absl::string_view name) const {
-  VMSDK_LOG(WARNING, nullptr) << "LOOKUP: " << db_num << " : " << name;
   auto db_itr = db_to_index_schemas_.find(db_num);
   if (db_itr == db_to_index_schemas_.end()) {
     return absl::NotFoundError(absl::StrCat("Index schema not found: ", name));