(spec taskpkg.EnqueueRun, ingress TaskIngressContext)
| 514 | } |
| 515 | |
| 516 | func withNetworkRunMetadata(spec taskpkg.EnqueueRun, ingress TaskIngressContext) (taskpkg.EnqueueRun, error) { |
| 517 | values, err := networkRunMetadataValues(ingress) |
| 518 | if err != nil { |
| 519 | return taskpkg.EnqueueRun{}, err |
| 520 | } |
| 521 | metadata, err := mergeTrustedNetworkMetadata(spec.Metadata, values) |
| 522 | if err != nil { |
| 523 | return taskpkg.EnqueueRun{}, err |
| 524 | } |
| 525 | spec.Metadata = metadata |
| 526 | return spec, nil |
| 527 | } |
| 528 | |
| 529 | func networkRunMetadataValues(ingress TaskIngressContext) (map[string]string, error) { |
| 530 | workID := strings.TrimSpace(ingress.WorkID) |
no test coverage detected