From cf058f5052890636eee4b54a3aad84c2fe55375a Mon Sep 17 00:00:00 2001 From: 7ttp <117663341+7ttp@users.noreply.github.com> Date: Fri, 1 May 2026 14:56:46 +0530 Subject: [PATCH 1/2] fix --- internal/seed/buckets/buckets.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/internal/seed/buckets/buckets.go b/internal/seed/buckets/buckets.go index b922e63d8f..afad6a36db 100644 --- a/internal/seed/buckets/buckets.go +++ b/internal/seed/buckets/buckets.go @@ -11,6 +11,9 @@ import ( ) func Run(ctx context.Context, projectRef string, interactive bool, fsys afero.Fs) error { + if len(projectRef) == 0 && len(utils.Config.Storage.Buckets) == 0 { + return nil + } api, err := client.NewStorageAPI(ctx, projectRef) if err != nil { return err From e033a04798deb4eefe337f18132098c97869186a Mon Sep 17 00:00:00 2001 From: 7ttp <117663341+7ttp@users.noreply.github.com> Date: Fri, 1 May 2026 14:57:08 +0530 Subject: [PATCH 2/2] test --- internal/seed/buckets/buckets_test.go | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/internal/seed/buckets/buckets_test.go b/internal/seed/buckets/buckets_test.go index 7194f390b7..687f904b2a 100644 --- a/internal/seed/buckets/buckets_test.go +++ b/internal/seed/buckets/buckets_test.go @@ -54,16 +54,24 @@ public = false` }) t.Run("ignores unconfigured buckets", func(t *testing.T) { - // Setup mock api - defer gock.OffAll() + t.Cleanup(func() { + utils.Config.Storage.TargetMigration = "" + gock.OffAll() + }) + utils.Config.Storage.TargetMigration = "custom-metadata" gock.New(utils.Config.Api.ExternalUrl). Get("/storage/v1/bucket"). - Reply(http.StatusOK). - JSON([]storage.BucketResponse{}) + Reply(http.StatusBadRequest). + JSON(map[string]string{ + "statusCode": "403", + "error": "Unauthorized", + "message": "new row violates row-level security policy", + }) // Run test err := Run(context.Background(), "", false, afero.NewMemMapFs()) // Check error assert.NoError(t, err) + assert.Len(t, gock.Pending(), 1) assert.Empty(t, apitest.ListUnmatchedRequests()) }) }