Add missing telemetry for empty Supabase queue consumer responses

Author: onurtemizkan

packages/core/src/integrations/supabase.ts

@@ -843,6 +843,16 @@ const _instrumentRpcConsumer = (target: unknown, thisArg: unknown, argumentsList
             DEBUG_BUILD && debug.log('Consumer received empty response', { queueName });
             span.setStatus({ code: SPAN_STATUS_OK });
             span.setAttribute('messaging.batch.message_count', 0);
+            // Set retry count to 0 for empty responses (no messages to retry)
+            span.setAttribute('messaging.message.retry.count', 0);
+            // Create breadcrumb for empty queue polling (consistent with non-empty responses)
+            const breadcrumbData: Record<string, unknown> = {
+              'messaging.batch.message_count': 0,
+            };
+            if (queueName) {
+              breadcrumbData['messaging.destination.name'] = queueName;
+            }
+            _createQueueBreadcrumb('queue.process', queueName, breadcrumbData);
             return res;
           }
 

packages/core/test/lib/integrations/supabase-queues.test.ts

@@ -942,6 +942,32 @@ describe('Supabase Queue Instrumentation', () => {
         }),
       );
     });
+
+    it('should create breadcrumb for empty consumer response', async () => {
+      const mockResponse: SupabaseResponse = {
+        data: [],
+        status: 200,
+      };
+
+      mockRpcFunction.mockResolvedValue(mockResponse);
+      instrumentSupabaseClient(mockSupabaseClient);
+
+      await mockSupabaseClient.rpc('pop', {
+        queue_name: 'empty-queue',
+      });
+
+      expect(addBreadcrumbSpy).toHaveBeenCalledWith(
+        expect.objectContaining({
+          type: 'supabase',
+          category: 'queue.process',
+          message: 'queue.process(empty-queue)',
+          data: expect.objectContaining({
+            'messaging.destination.name': 'empty-queue',
+            'messaging.batch.message_count': 0,
+          }),
+        }),
+      );
+    });
   });
 
   describe('Span Attributes', () => {