return error in activity worker

lovromazgon · lovromazgon · commit 27001d1ea34d · 2023-09-21T12:57:52.000+02:00
diff --git a/internal/worker/activity.go b/internal/worker/activity.go
@@ -201,6 +201,8 @@ func (aw *ActivityWorker) poll(ctx context.Context, timeout time.Duration) (*tas
 		if errors.Is(err, context.DeadlineExceeded) {
 			return nil, nil
 		}
+		
+		return nil, err
 	}
 
 	return task, nil

Original file line number	Diff line number	Diff line change
`@@ -201,6 +201,8 @@ func (aw ActivityWorker) poll(ctx context.Context, timeout time.Duration) (tas`
`201`	`201`	`if errors.Is(err, context.DeadlineExceeded) {`
`202`	`202`	`return nil, nil`
`203`	`203`	`}`
	`204`	`+`
	`205`	`+ return nil, err`
`204`	`206`	`}`
`205`	`207`
`206`	`208`	`return task, nil`