( message string, err error, payload hookspkg.TaskRunEnqueuedPayload, )
| 669 | } |
| 670 | |
| 671 | func (r *taskRoleRuntime) logTaskRoleError( |
| 672 | message string, |
| 673 | err error, |
| 674 | payload hookspkg.TaskRunEnqueuedPayload, |
| 675 | ) { |
| 676 | if r == nil { |
| 677 | return |
| 678 | } |
| 679 | args := []any{ |
| 680 | taskRoleRuntimeTaskIDKey, strings.TrimSpace(payload.TaskID), |
| 681 | "run_id", strings.TrimSpace(payload.RunID), |
| 682 | taskRoleRuntimeWorkspaceIDKey, strings.TrimSpace(payload.WorkspaceID), |
| 683 | "coordination_channel_id", strings.TrimSpace(payload.CoordinationChannelID), |
| 684 | } |
| 685 | if err != nil { |
| 686 | args = append(args, "error", err) |
| 687 | } |
| 688 | r.logger.Warn(message, args...) |
| 689 | } |
no test coverage detected