debug url variations

Arize-ai · Jun 5, 2024 · c18011e · c18011e
1 parent dd7569c
commit c18011e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/broker/client/reader.go b/broker/client/reader.go
@@ -173,6 +173,9 @@ func (r *Reader) Read(p []byte) (n int, err error) {
 
 	// If the frame preceding EOF provided a fragment URL, open it directly.
 	if !r.Request.MetadataOnly && r.Response.Status == pb.Status_OK && r.Response.FragmentUrl != "" {
+		log.WithFields(log.Fields{
+			"FragmentUrl": r.Response.FragmentUrl,
+		}).Info("reader handle FragmentUrl")
 		if TransformSignedURLs {
 			var fragURL *url.URL
 			if fragURL, err = url.Parse(r.Response.FragmentUrl); err != nil {

diff --git a/broker/fragment/store_gcs.go b/broker/fragment/store_gcs.go
@@ -44,6 +44,10 @@ func (s *gcsBackend) SignGet(ep *url.URL, fragment pb.Fragment, d time.Duration)
 	}
 
 	if DisableSignedUrls {
+		log.WithFields(log.Fields{
+			"ep":       fmt.Sprintf("%v", *ep),
+			"fragment": fmt.Sprintf("%v", fragment),
+		}).Info("signGet disable signed urls")
 		u := &url.URL{
 			Path: fmt.Sprintf("/%s/%s", cfg.bucket, cfg.rewritePath(cfg.prefix, fragment.ContentPath())),
 		}