Skip to content

Commit

Permalink
annotate request with id
Browse files Browse the repository at this point in the history
Signed-off-by: Rumen Vasilev <[email protected]>
  • Loading branch information
rumenvasilev committed Nov 6, 2023
1 parent d119df6 commit 95255f8
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion internal/core/analysis.go
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ func analyzeWorker(ctx context.Context, workerID int, wg *sync.WaitGroup, ch cha
for {
select {
case <-ctx.Done():
log.Info("Job cancellation requested.")
log.Info("[THREAD #%d] Job cancellation requested.", workerID)
wg.Done()
return
case repo, ok := <-ch:
Expand Down
2 changes: 1 addition & 1 deletion internal/core/retrieve_worker.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ func retrieveReposWorker(ctx context.Context, workerID int, wg *sync.WaitGroup,
for {
select {
case <-ctx.Done():
log.Info("Job cancellation requested.")
log.Info("[THREAD #%d] Job cancellation requested.", workerID)
wg.Done()
return
case target, ok := <-ch:
Expand Down

0 comments on commit 95255f8

Please sign in to comment.