(rootTaskID string, idx int)
| 1131 | } |
| 1132 | |
| 1133 | func cancellationPropagationRoot(rootTaskID string, idx int) string { |
| 1134 | if idx == 0 { |
| 1135 | return "" |
| 1136 | } |
| 1137 | return rootTaskID |
| 1138 | } |
| 1139 | |
| 1140 | func (m *Service) cancelOpenTaskRuns( |
| 1141 | ctx context.Context, |
no outgoing calls
no test coverage detected