diff --git a/cmd/monwork/main.go b/cmd/monwork/main.go index d7f0791..782baf7 100644 --- a/cmd/monwork/main.go +++ b/cmd/monwork/main.go @@ -74,6 +74,7 @@ func startNodeGen(db *sql.DB, checkInterval time.Duration) { log.Printf("could not update nodes: %s", err) tx.Rollback() time.Sleep(checkInterval) + continue } if err := tx.Commit(); err != nil { log.Printf("could not commit node updates: %s", err) @@ -100,6 +101,7 @@ func startCommandGen(db *sql.DB, checkInterval time.Duration) { log.Printf("could not update checks: %s", err) tx.Rollback() time.Sleep(checkInterval) + continue } if err := tx.Commit(); err != nil { log.Printf("could not commit command updates: %s", err)