From 43f8332297fd393005339c4475cea6eb0c328c36 Mon Sep 17 00:00:00 2001 From: chrislu Date: Thu, 4 Sep 2025 23:14:36 -0700 Subject: [PATCH] normal if no partitions found --- weed/query/engine/hybrid_message_scanner.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/weed/query/engine/hybrid_message_scanner.go b/weed/query/engine/hybrid_message_scanner.go index a7fba21bf..a73f0a2e6 100644 --- a/weed/query/engine/hybrid_message_scanner.go +++ b/weed/query/engine/hybrid_message_scanner.go @@ -446,9 +446,10 @@ func (hms *HybridMessageScanner) discoverTopicPartitions(ctx context.Context) ([ return nil, fmt.Errorf("failed to scan topic directory for partitions: %v", err) } - // If no partitions found, return error instead of masking the issue + // If no partitions found, return empty slice (valid for newly created or empty topics) if len(allPartitions) == 0 { - return nil, fmt.Errorf("no partitions found for topic %s", hms.topic.String()) + fmt.Printf("No partitions found for topic %s - returning empty result set\n", hms.topic.String()) + return []topic.Partition{}, nil } fmt.Printf("Discovered %d partitions for topic %s\n", len(allPartitions), hms.topic.String())