Skip to content

Commit

Permalink
[*] prettify log strings
Browse files Browse the repository at this point in the history
  • Loading branch information
pashagolub committed May 20, 2020
1 parent acf02ec commit 65afcb1
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion internal/pgengine/transaction.go
Expand Up @@ -59,7 +59,7 @@ func MustRollbackTransaction(tx *sqlx.Tx) {
}

func mustSavepoint(tx *sqlx.Tx, savepoint string) {
LogToDB("DEBUG", "Define savepoint to ignore an error for the task: ")
LogToDB("DEBUG", "Define savepoint to ignore an error for the task: ", strconv.Quote(savepoint))
_, err := tx.Exec("SAVEPOINT " + strconv.Quote(savepoint))
if err != nil {
LogToDB("ERROR", err)
Expand Down
2 changes: 1 addition & 1 deletion internal/scheduler/interval_chain.go
Expand Up @@ -45,7 +45,7 @@ func (ichain IntervalChain) reschedule(ctx context.Context) {
pgengine.DeleteChainConfig(ctx, ichain.ChainExecutionConfigID)
return
}
pgengine.LogToDB("DEBUG", fmt.Sprintf("Sleeping before next execution in %ds for chain %s", ichain.Interval, ichain))
pgengine.LogToDB("DEBUG", fmt.Sprintf("Sleeping before next execution for %ds for chain %s", ichain.Interval, ichain))
time.Sleep(time.Duration(ichain.Interval) * time.Second)
if ichain.isValid() {
intervalChainsChan <- ichain
Expand Down

0 comments on commit 65afcb1

Please sign in to comment.