From a1949d8c18baf5dee20ecb7ec40b16c788509070 Mon Sep 17 00:00:00 2001 From: Ilian Aleixev Date: Thu, 25 Apr 2024 12:40:43 -0500 Subject: [PATCH 1/4] Add println to client.execute for debug purposes --- CHANGELOG.md | 7 +++++-- rai/client.go | 7 ++++++- 2 files changed, 11 insertions(+), 3 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index e9823db..97b54e1 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,10 +1,13 @@ # Changelog +## v0.5.13-alpha +* Added print outs for client.execute. + ## 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..2160a81 100644 --- a/rai/client.go +++ b/rai/client.go @@ -974,6 +974,7 @@ func (c *Client) Execute( return nil, err } if isTransactionComplete(&rsp.Transaction) { + fmt.Println(fmt.Sprintf("Txn state: %s.", rsp.Transaction.State)) return rsp, nil // fast path } id := rsp.Transaction.ID @@ -985,13 +986,17 @@ func (c *Client) Execute( return nil, err } if isTransactionComplete(&rsp.Transaction) { + fmt.Println(fmt.Sprintf("Txn %s state: %s.", id, rsp.Transaction.State)) return rsp, nil } - delta := time.Since(t0) // total run time + fmt.Println(fmt.Sprintf("Txn %s state: %s.", id, rsp.Transaction.State)) + delta := time.Since(t0) // total run time + fmt.Println(fmt.Sprintf("Delta is %s.", delta)) pause := time.Duration(int64(delta) / 5) // 20% of total run time if pause > twoMinutes { pause = twoMinutes } + fmt.Println(fmt.Sprintf("Pause took %s.", pause)) time.Sleep(pause) } } From 56424bdb5bf2c9cd13f8ced442829d82c4889e7c Mon Sep 17 00:00:00 2001 From: Ilian Aleixev Date: Thu, 25 Apr 2024 12:48:57 -0500 Subject: [PATCH 2/4] Cleanup --- CHANGELOG.md | 5 ++++- rai/client.go | 10 +++++----- 2 files changed, 9 insertions(+), 6 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 97b54e1..04bcf26 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,8 +1,11 @@ # Changelog -## v0.5.13-alpha +## 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. diff --git a/rai/client.go b/rai/client.go index 2160a81..76764ac 100644 --- a/rai/client.go +++ b/rai/client.go @@ -974,7 +974,7 @@ func (c *Client) Execute( return nil, err } if isTransactionComplete(&rsp.Transaction) { - fmt.Println(fmt.Sprintf("Txn state: %s.", rsp.Transaction.State)) + fmt.Printf("Txn state: %s.\n", rsp.Transaction.State) return rsp, nil // fast path } id := rsp.Transaction.ID @@ -986,17 +986,17 @@ func (c *Client) Execute( return nil, err } if isTransactionComplete(&rsp.Transaction) { - fmt.Println(fmt.Sprintf("Txn %s state: %s.", id, rsp.Transaction.State)) + fmt.Printf("Txn %s state: %s.", id, rsp.Transaction.State) return rsp, nil } - fmt.Println(fmt.Sprintf("Txn %s state: %s.", id, rsp.Transaction.State)) + fmt.Printf("Txn %s state: %s.", id, rsp.Transaction.State) delta := time.Since(t0) // total run time - fmt.Println(fmt.Sprintf("Delta is %s.", delta)) + fmt.Printf("Delta is %s.", delta) pause := time.Duration(int64(delta) / 5) // 20% of total run time if pause > twoMinutes { pause = twoMinutes } - fmt.Println(fmt.Sprintf("Pause took %s.", pause)) + fmt.Printf("Pause took %s.", pause) time.Sleep(pause) } } From 88af0f07a6d2d46c2663dbeaf0d1fd7751b54184 Mon Sep 17 00:00:00 2001 From: Ilian Aleixev Date: Thu, 25 Apr 2024 13:51:48 -0500 Subject: [PATCH 3/4] Update version --- rai/version.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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" From 6c8c27f25f7bb054b1edb9ee1850019aa5ba70dc Mon Sep 17 00:00:00 2001 From: Ilian Aleixev Date: Thu, 25 Apr 2024 13:53:54 -0500 Subject: [PATCH 4/4] Switch to log --- rai/client.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/rai/client.go b/rai/client.go index 76764ac..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,7 +975,7 @@ func (c *Client) Execute( return nil, err } if isTransactionComplete(&rsp.Transaction) { - fmt.Printf("Txn state: %s.\n", rsp.Transaction.State) + log.Printf("Txn state: %s.\n", rsp.Transaction.State) return rsp, nil // fast path } id := rsp.Transaction.ID @@ -986,17 +987,17 @@ func (c *Client) Execute( return nil, err } if isTransactionComplete(&rsp.Transaction) { - fmt.Printf("Txn %s state: %s.", id, rsp.Transaction.State) + log.Printf("Txn %s state: %s.", id, rsp.Transaction.State) return rsp, nil } - fmt.Printf("Txn %s state: %s.", id, rsp.Transaction.State) + log.Printf("Txn %s state: %s.", id, rsp.Transaction.State) delta := time.Since(t0) // total run time - fmt.Printf("Delta is %s.", delta) + log.Printf("Delta is %s.", delta) pause := time.Duration(int64(delta) / 5) // 20% of total run time if pause > twoMinutes { pause = twoMinutes } - fmt.Printf("Pause took %s.", pause) + log.Printf("Pause took %s.", pause) time.Sleep(pause) } }