From 80ec1a2a16dcb34d3cda9744ae2ed32113526c47 Mon Sep 17 00:00:00 2001 From: nquidox Date: Mon, 6 Apr 2026 12:46:55 +0300 Subject: [PATCH] ctx fix --- internal/task/service.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/internal/task/service.go b/internal/task/service.go index 39cba20..cf5c3a7 100644 --- a/internal/task/service.go +++ b/internal/task/service.go @@ -23,9 +23,12 @@ func newService(mp common.MerchProvider) *service { } func (s *service) RequestTasks(_ *emptypb.Empty, stream tt.TaskProcessor_RequestTasksServer) error { - tasks, err := s.merchProvider.GetTasks(stream.Context()) + ctx, cancel := context.WithCancel(context.Background()) + + tasks, err := s.merchProvider.GetTasks(ctx) if err != nil { log.WithError(err).Errorf("%v Failed to get tasks", pkgLogHeader) + cancel() return err } @@ -35,10 +38,11 @@ func (s *service) RequestTasks(_ *emptypb.Empty, stream tt.TaskProcessor_Request Origins: task.Origins, }); err != nil { log.WithError(err).Errorf("%v Failed to send tasks", pkgLogHeader) + cancel() return err } } - + cancel() return nil }