luzifer/tex-api
1
0
Fork 0
mirror of https://github.com/Luzifer/tex-api.git synced 2024-11-09 16:50:03 +00:00
Code Issues Releases Wiki Activity

Add more verbose processing logs

Browse source 
Signed-off-by: Knut Ahlers <knut@ahlers.me>
This commit is contained in:
Knut Ahlers 2018-09-17 12:17:52 +02:00
parent a6fd458d40
commit 6048a58d28
Signed by: luzifer
GPG key ID: DC2729FDD34BE99E
1 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
main.go
View file

@ -270,27 +270,31 @@ func downloadAssets(res http.ResponseWriter, r *http.Request) {
} }
func jobProcessor(uid uuid.UUID) { func jobProcessor(uid uuid.UUID) {
logger := log.WithField("uuid", uid)
logger.Info("Started processing")
processingDir := path.Dir(pathFromUUID(uid, filenameStatus)) processingDir := path.Dir(pathFromUUID(uid, filenameStatus))
status, err := loadStatusByUUID(uid) status, err := loadStatusByUUID(uid)
if err != nil { if err != nil {
log.WithError(err).Error("Unable to load status file in processing job") logger.WithError(err).Error("Unable to load status file in processing job")
return return
} }
cmd := exec.Command("/bin/bash", cfg.Script) // #nosec G204 cmd := exec.Command("/bin/bash", cfg.Script) // #nosec G204
cmd.Dir = processingDir cmd.Dir = processingDir
cmd.Stderr = log.StandardLogger().WriterLevel(log.ErrorLevel) cmd.Stderr = logger.WriterLevel(log.InfoLevel) // Bash uses stderr for `-x` parameter
status.UpdateStatus(statusStarted) status.UpdateStatus(statusStarted)
if err := status.Save(); err != nil { if err := status.Save(); err != nil {
log.WithError(err).Error("Unable to save status file") logger.WithError(err).Error("Unable to save status file")
return return
} }
if err := cmd.Run(); err != nil { if err := cmd.Run(); err != nil {
logger.WithError(err).Error("Processing failed")
status.UpdateStatus(statusError) status.UpdateStatus(statusError)
if err := status.Save(); err != nil { if err := status.Save(); err != nil {
log.WithError(err).Error("Unable to save status file") logger.WithError(err).Error("Unable to save status file")
return return
} }
return return
@ -298,7 +302,8 @@ func jobProcessor(uid uuid.UUID) {
status.UpdateStatus(statusFinished) status.UpdateStatus(statusFinished)
if err := status.Save(); err != nil { if err := status.Save(); err != nil {
log.WithError(err).Error("Unable to save status file") logger.WithError(err).Error("Unable to save status file")
return return
} }
logger.Info("Finished processing")
} }