()
| 117 | } |
| 118 | |
| 119 | func (tqs *TaskQueueSet) GetMain() *TaskQueue { |
| 120 | return tqs.GetByName(tqs.MainName) |
| 121 | } |
| 122 | |
| 123 | func (tqs *TaskQueueSet) AddTailTasks(tasks ...task.Task) { |
| 124 | tqs.logger.Debug("AddTailTasks: adding tasks to queues", slog.Int(pkg.LogKeyTasksCount, len(tasks))) |