code refactoring

2024-08-20 20:29:32 +02:00
parent c51f320a6f
commit 8f2d9eaf6e
6 changed files with 20 additions and 17 deletions
--- a/server/internal/message_queue.go
+++ b/server/internal/message_queue.go
@@ -53,7 +53,6 @@ func (m *MessageQueue) downloadConsumer() {
 	sem := semaphore.NewWeighted(int64(m.concurrency))

 	m.eventBus.SubscribeAsync(queueName, func(p *Process) {
-		//TODO: provide valid context
 		sem.Acquire(context.Background(), 1)
 		defer sem.Release(1)

@@ -82,8 +81,7 @@ func (m *MessageQueue) metadataSubscriber() {
 	sem := semaphore.NewWeighted(1)

 	m.eventBus.SubscribeAsync(queueName, func(p *Process) {
-		//TODO: provide valid context
-		sem.Acquire(context.TODO(), 1)
+		sem.Acquire(context.Background(), 1)
 		defer sem.Release(1)

 		slog.Info("received process from event bus",