do not silently ignore errors in ActivityWorker.poll

vroldanbet · Sep 20, 2023 · ec90b5b · ec90b5b
1 parent e7f0218
commit ec90b5b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/worker/activity.go b/internal/worker/activity.go
@@ -197,6 +197,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