X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/dfb995ab9ea0f1d8808c812870db717164ac95f4..bdb92619b5f6d920119b8c32c3027cf4b751ed16:/services/ws/event.go diff --git a/services/ws/event.go b/services/ws/event.go index 77acf4496f..fa2a5df1b0 100644 --- a/services/ws/event.go +++ b/services/ws/event.go @@ -2,7 +2,6 @@ package main import ( "database/sql" - "log" "sync" "time" @@ -23,6 +22,7 @@ type eventSource interface { type event struct { LogID uint64 Received time.Time + Ready time.Time Serial uint64 db *sql.DB @@ -51,12 +51,12 @@ func (e *event) Detail() *arvados.Log { &logRow.CreatedAt, &propYAML) if e.err != nil { - log.Printf("retrieving log row %d: %s", e.LogID, e.err) + logger(nil).WithField("LogID", e.LogID).WithError(e.err).Error("QueryRow failed") return nil } e.err = yaml.Unmarshal(propYAML, &logRow.Properties) if e.err != nil { - log.Printf("decoding yaml for log row %d: %s", e.LogID, e.err) + logger(nil).WithField("LogID", e.LogID).WithError(e.err).Error("yaml decode failed") return nil } e.logRow = &logRow