Skip to content

Commit

Permalink
fix: remove ctx
Browse files Browse the repository at this point in the history
Signed-off-by: Vladislav Sukhin <[email protected]>
  • Loading branch information
vsukhin committed Nov 29, 2024
1 parent 97b5bd3 commit 3e2c45f
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions pkg/agent/testworkflows.go
Original file line number Diff line number Diff line change
Expand Up @@ -243,9 +243,6 @@ func (ag *Agent) executeWorkflowNotificationsRequest(ctx context.Context, req *c
}

func (ag *Agent) executeWorkflowServiceNotificationsRequest(ctx context.Context, req *cloud.TestWorkflowServiceNotificationsRequest) error {
timeoutCtx, cancel := context.WithTimeout(ctx, serviceWaitTimeout)
defer cancel()

notificationsCh, err := retry.DoWithData(
func() (<-chan testkube.TestWorkflowExecutionNotification, error) {
// We have a race condition here
Expand All @@ -256,7 +253,6 @@ func (ag *Agent) executeWorkflowServiceNotificationsRequest(ctx context.Context,
},
retry.DelayType(retry.FixedDelay),
retry.Delay(logRetryDelay),
retry.Context(timeoutCtx),
retry.RetryIf(func(err error) bool {
return errors.Is(err, registry.ErrResourceNotFound)
}),
Expand Down

0 comments on commit 3e2c45f

Please sign in to comment.