(ctx context.Context)
| 196 | ) |
| 197 | |
| 198 | func getDefaultNamespace(ctx context.Context) string { |
| 199 | return internal.IncomingHeaders(ctx).Get(defaultNamespace) |
| 200 | } |
| 201 | |
| 202 | func newAddReq(c context.Context, task *Task, queueName string) (*pb.TaskQueueAddRequest, error) { |
| 203 | if queueName == "" { |
no test coverage detected
searching dependent graphs…