(parentLogger log.Logger, task *models.Task)
| 439 | } |
| 440 | |
| 441 | func getTaskLogger(parentLogger log.Logger, task *models.Task) (log.Logger, errors.Error) { |
| 442 | logger := parentLogger.Nested(fmt.Sprintf("task #%d", task.ID)) |
| 443 | loggingPath := logruslog.GetTaskLoggerPath(logger.GetConfig(), task) |
| 444 | stream, err := logruslog.GetFileStream(loggingPath) |
| 445 | if err != nil { |
| 446 | return nil, err |
| 447 | } |
| 448 | logger.SetStream(&log.LoggerStreamConfig{ |
| 449 | Path: loggingPath, |
| 450 | Writer: stream, |
| 451 | }) |
| 452 | return logger, nil |
| 453 | } |