( ctx context.Context, opts *options, task *workflowservice.PollWorkflowTaskQueueResponse, handler func(task *workflowservice.PollWorkflowTaskQueueResponse) (*workflowservice.RespondWorkflowTaskCompletedRequest, error), )
| 447 | } |
| 448 | |
| 449 | func (p *workflowTaskPoller) handleTask( |
| 450 | ctx context.Context, |
| 451 | opts *options, |
| 452 | task *workflowservice.PollWorkflowTaskQueueResponse, |
| 453 | handler func(task *workflowservice.PollWorkflowTaskQueueResponse) (*workflowservice.RespondWorkflowTaskCompletedRequest, error), |
| 454 | ) (*workflowservice.RespondWorkflowTaskCompletedResponse, error) { |
| 455 | p.t.Helper() |
| 456 | reply, err := handler(task) |
| 457 | if err != nil { |
| 458 | return nil, p.respondTaskFailed(ctx, opts, task.TaskToken, err) |
| 459 | } |
| 460 | |
| 461 | resp, err := p.respondTaskCompleted(ctx, opts, task, reply) |
| 462 | if err != nil { |
| 463 | return nil, err |
| 464 | } |
| 465 | |
| 466 | return resp, nil |
| 467 | } |
| 468 | |
| 469 | func (p *workflowTaskPoller) respondQueryTaskCompleted( |
| 470 | ctx context.Context, |
no test coverage detected