From d877928f111654331625d6db538f40488de19687 Mon Sep 17 00:00:00 2001 From: Deluan Date: Tue, 28 Jul 2020 17:16:01 -0400 Subject: [PATCH] Add UpdatedAt to transcoding cache key --- core/media_streamer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/media_streamer.go b/core/media_streamer.go index b43881921..6d3347a4c 100644 --- a/core/media_streamer.go +++ b/core/media_streamer.go @@ -40,7 +40,7 @@ type streamJob struct { } func (j *streamJob) String() string { - return fmt.Sprintf("%s.%d.%s", j.mf.ID, j.bitRate, j.format) + return fmt.Sprintf("%s.%s.%d.%s", j.mf.ID, j.mf.UpdatedAt.Format(time.RFC3339Nano), j.bitRate, j.format) } func (ms *mediaStreamer) NewStream(ctx context.Context, id string, reqFormat string, reqBitRate int) (*Stream, error) {