diff --git a/CHANGELOG.md b/CHANGELOG.md index e9823db..04bcf26 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,10 +1,16 @@ # Changelog +## v0.5.14-alpha +* Added print outs for client.execute. + +## v0.5.13-alpha +* Fix (u)int128/hash handling. + ## v0.5.12-alpha -* Add beta version of snowflake datastream APIs. +* Add beta version of snowflake datastream APIs. ## v0.5.11-alpha -* Add ability to start and stop engines. +* Add ability to start and stop engines. ## v0.5.10-alpha * `X-Request-Id` is generated for every HTTP request. diff --git a/rai/client.go b/rai/client.go index b181258..3577e0a 100644 --- a/rai/client.go +++ b/rai/client.go @@ -20,6 +20,7 @@ import ( "fmt" "io" "io/ioutil" + "log" "mime" "mime/multipart" "net/http" @@ -974,6 +975,7 @@ func (c *Client) Execute( return nil, err } if isTransactionComplete(&rsp.Transaction) { + log.Printf("Txn state: %s.\n", rsp.Transaction.State) return rsp, nil // fast path } id := rsp.Transaction.ID @@ -985,13 +987,17 @@ func (c *Client) Execute( return nil, err } if isTransactionComplete(&rsp.Transaction) { + log.Printf("Txn %s state: %s.", id, rsp.Transaction.State) return rsp, nil } - delta := time.Since(t0) // total run time + log.Printf("Txn %s state: %s.", id, rsp.Transaction.State) + delta := time.Since(t0) // total run time + log.Printf("Delta is %s.", delta) pause := time.Duration(int64(delta) / 5) // 20% of total run time if pause > twoMinutes { pause = twoMinutes } + log.Printf("Pause took %s.", pause) time.Sleep(pause) } } diff --git a/rai/version.go b/rai/version.go index 0482f58..16e6148 100644 --- a/rai/version.go +++ b/rai/version.go @@ -14,4 +14,4 @@ package rai -const Version = "0.5.12-alpha" +const Version = "0.5.14-alpha"