From 0ec1f87b2b51729fa3d8f2b2d3080b116d782431 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ren=C3=A1n=20Del=20Valle?= Date: Fri, 15 Oct 2021 19:47:20 -0700 Subject: [PATCH] Minor fix in an attempt to get CI to pass --- jobUpdate.go | 2 +- realis_e2e_test.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/jobUpdate.go b/jobUpdate.go index 248a65d..d880c29 100644 --- a/jobUpdate.go +++ b/jobUpdate.go @@ -77,7 +77,7 @@ func (j *JobUpdate) BatchSize(size int32) *JobUpdate { // Minimum number of seconds a shard must remain in RUNNING state before considered a success. func (j *JobUpdate) WatchTime(timeout time.Duration) *JobUpdate { - j.request.Settings.MinWaitInInstanceRunningMs = int32(timeout.Seconds() * 1000) + j.request.Settings.MinWaitInInstanceRunningMs = int32(timeout.Milliseconds()) return j } diff --git a/realis_e2e_test.go b/realis_e2e_test.go index 676ed84..7977f62 100644 --- a/realis_e2e_test.go +++ b/realis_e2e_test.go @@ -822,7 +822,7 @@ func TestRealisClient_BatchAwareAutoPause(t *testing.T) { strategy := realis.JobUpdateFromAuroraTask(job.AuroraTask()). VariableBatchStrategy(true, updateGroups...). InstanceCount(6). - WatchTime(1000) + WatchTime(time.Second*1) result, err := r.StartJobUpdate(strategy, "") require.NoError(t, err)