Skip to content

Commit

Permalink
refactor(core): Tiny fix - use maps.Clone in filestream
Browse files Browse the repository at this point in the history
Reviewers: kptkin

Reviewed By: kptkin

Pull Request: #7567
  • Loading branch information
timoffex committed May 7, 2024
1 parent 2ebd7be commit ab50714
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions core/pkg/filestream/filestream.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@ package filestream

import (
"fmt"
"maps"
"sync"
"time"

Expand Down Expand Up @@ -207,10 +208,7 @@ func (fs *fileStream) Start(
project,
runID,
)

for k, v := range offsetMap {
fs.offsetMap[k] = v
}
fs.offsetMap = maps.Clone(offsetMap)

fs.processWait.Add(1)
go func() {
Expand Down

0 comments on commit ab50714

Please sign in to comment.