adds trace log messages to LR

to troubleshoot potential deadlock

internal/graph/checkingresourcestream.go

@@ -3,6 +3,7 @@ package graph
 import (
 	"cmp"
 	"context"
+	log "github.com/authzed/spicedb/internal/logging"
 	"slices"
 	"sync"
 
@@ -279,21 +280,26 @@ func newCheckingResourceStream(
 // waitForPublishing waits for the publishing goroutine to complete its work, and returns the number
 // of published *reachable* resources or the error that occurred during checking or publishing.
 func (crs *checkingResourceStream) waitForPublishing() (uint64, *v1.Cursor, error) {
+
+	log.Trace().Msg("marking reachable resources completed")
 	// Mark that no new items will come in from the reachable resources stream.
 	for i := 0; i < int(crs.concurrencyLimit); i++ {
 		crs.reachableResourcesCompleted <- struct{}{}
 	}
 
 	// Wait for all existing processing to complete.
+	log.Trace().Msg("waiting for all existing processing to complete")
 	crs.processingWaitGroup.Wait()
 
 	// Run a final processing call to ensure there are no remaining items.
+	log.Trace().Msg("making sure there are no remaining items in the checking stream")
 	_, err := crs.runProcess(true)
 	if err != nil {
 		return 0, nil, err
 	}
 
 	// Mark publishing as ready for final publishing.
+	log.Trace().Msg("marking publishing as ready for final publishing")
 	select {
 	case crs.availableForPublishing <- false:
 		break
@@ -304,6 +310,7 @@ func (crs *checkingResourceStream) waitForPublishing() (uint64, *v1.Cursor, erro
 	}
 
 	// Wait for any remaining publishing to complete.
+	log.Trace().Msg("waiting for any remaining publishing to complete")
 	crs.publishingWaitGroup.Wait()
 
 	return crs.reachableResourcesCount, crs.lastReachableResourceCursor, crs.err

internal/graph/lookupresources.go

@@ -3,6 +3,7 @@ package graph
 import (
 	"context"
 	"errors"
+	log "github.com/authzed/spicedb/internal/logging"
 
 	"github.com/authzed/spicedb/internal/dispatch"
 	"github.com/authzed/spicedb/pkg/datastore"
@@ -77,11 +78,13 @@ func (cl *CursoredLookupResources) LookupResources(
 			}
 		}
 
+		log.Trace().Msg("waiting for checking stream publishing")
 		reachableCount, newCursor, err := checkingStream.waitForPublishing()
 		if err != nil {
 			return err
 		}
 
+		log.Trace().Uint64("reachable-count", reachableCount).Msg("completed checking stream publishing")
 		reachableResourcesCursor = newCursor
 		if reachableCount == 0 {
 			return nil