improve logging

This commit is contained in:
Brad Rydzewski 2017-06-29 17:30:08 -04:00
parent ba23d05231
commit a27b21909c

View file

@ -306,9 +306,13 @@ func run(ctx context.Context, client rpc.Peer, filter rpc.Filter) error {
uploads.Wait()
log.Printf("pipeline: logging complete: %s", work.ID)
err = client.Done(context.Background(), work.ID, state)
if err != nil {
log.Printf("Pipeine: error signaling pipeline done: %s: %s", work.ID, err)
} else {
log.Printf("pipeline: done: %s", work.ID)
}
return nil