From d5fc2d687b49dec046a3d19f35e8c26735c28f6e Mon Sep 17 00:00:00 2001 From: Vchen7629 Date: Wed, 15 Apr 2026 11:07:10 -0700 Subject: [PATCH 1/2] fix(ci): added missing video-status path filter --- .github/workflows/ci.yaml | 1 + 1 file changed, 1 insertion(+) diff --git a/.github/workflows/ci.yaml b/.github/workflows/ci.yaml index 7918069..30e969f 100644 --- a/.github/workflows/ci.yaml +++ b/.github/workflows/ci.yaml @@ -20,6 +20,7 @@ jobs: transcoder_worker: ${{ steps.changes.outputs.transcoder_worker }} video_recombiner: ${{ steps.changes.outputs.video_recombiner }} video_upload: ${{ steps.changes.outputs.video_upload }} + video_status: ${{ steps.changes.outputs.video_status }} steps: - uses: actions/checkout@v4 - uses: dorny/paths-filter@v3 From a3ae57045b79c85b7b8a23d1f2cd6f373e79c6a4 Mon Sep 17 00:00:00 2001 From: Vchen7629 Date: Wed, 15 Apr 2026 11:10:12 -0700 Subject: [PATCH 2/2] fix(backend): added retry to nats_fixture.go in video-upload and video-recombiner to fix github actions test fail issue --- backend/video-recombiner/internal/test/nats_fixtures.go | 7 ++++++- backend/video-upload/cmd/helpers_test.go | 2 +- backend/video-upload/internal/handler/job_status_kv.go | 2 +- backend/video-upload/internal/test/nats_fixtures.go | 8 +++++++- 4 files changed, 15 insertions(+), 4 deletions(-) diff --git a/backend/video-recombiner/internal/test/nats_fixtures.go b/backend/video-recombiner/internal/test/nats_fixtures.go index eb4fa36..94ea9a3 100644 --- a/backend/video-recombiner/internal/test/nats_fixtures.go +++ b/backend/video-recombiner/internal/test/nats_fixtures.go @@ -5,6 +5,7 @@ package test import ( "context" "testing" + "time" "github.com/nats-io/nats.go" "github.com/nats-io/nats.go/jetstream" @@ -26,7 +27,11 @@ func SetupNats(t *testing.T) (jetstream.JetStream, *nats.Conn) { url, err := container.ConnectionString(ctx) require.NoError(t, err) - nc, err := nats.Connect(url) + nc, err := nats.Connect(url, + nats.RetryOnFailedConnect(true), + nats.MaxReconnects(10), + nats.ReconnectWait(200*time.Millisecond), + ) require.NoError(t, err) t.Cleanup(nc.Close) diff --git a/backend/video-upload/cmd/helpers_test.go b/backend/video-upload/cmd/helpers_test.go index aa93ff6..578cae9 100644 --- a/backend/video-upload/cmd/helpers_test.go +++ b/backend/video-upload/cmd/helpers_test.go @@ -44,4 +44,4 @@ func startTestServer(t *testing.T, kv jetstream.KeyValue) (*http.Server, *Config t.Cleanup(func() { server.Shutdown(context.Background()) }) //nolint:errcheck return server, cfg -} \ No newline at end of file +} diff --git a/backend/video-upload/internal/handler/job_status_kv.go b/backend/video-upload/internal/handler/job_status_kv.go index c9751a3..fceb601 100644 --- a/backend/video-upload/internal/handler/job_status_kv.go +++ b/backend/video-upload/internal/handler/job_status_kv.go @@ -43,4 +43,4 @@ func updateJobStatusKV(ctx context.Context, jobID string, kv jetstream.KeyValue, } return nil -} \ No newline at end of file +} diff --git a/backend/video-upload/internal/test/nats_fixtures.go b/backend/video-upload/internal/test/nats_fixtures.go index e29fedc..e006884 100644 --- a/backend/video-upload/internal/test/nats_fixtures.go +++ b/backend/video-upload/internal/test/nats_fixtures.go @@ -5,6 +5,7 @@ package test import ( "context" "testing" + "time" "github.com/nats-io/nats.go" "github.com/nats-io/nats.go/jetstream" @@ -26,7 +27,12 @@ func SetupNats(t *testing.T) (jetstream.JetStream, *nats.Conn) { url, err := container.ConnectionString(ctx) require.NoError(t, err) - nc, err := nats.Connect(url) + nc, err := nats.Connect(url, + nats.RetryOnFailedConnect(true), + nats.MaxReconnects(10), + nats.ReconnectWait(200*time.Millisecond), + ) + require.NoError(t, err) t.Cleanup(nc.Close)