ridv/gorealis-v2
1
0
Fork 0
Code Issues Pull requests Projects Releases 13 Packages Wiki Activity Actions

Minor fix in an attempt to get CI to pass

Browse source
This commit is contained in:
Renán Del Valle 2021-10-15 19:47:20 -07:00
parent 36edefda5d
commit 0ec1f87b2b
No known key found for this signature in database
GPG key ID: C240AD6D6F443EC9
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
jobUpdate.go
View file

@ -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. // Minimum number of seconds a shard must remain in RUNNING state before considered a success.
func (j *JobUpdate) WatchTime(timeout time.Duration) *JobUpdate { 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 return j
} }

2
realis_e2e_test.go
View file

@ -822,7 +822,7 @@ func TestRealisClient_BatchAwareAutoPause(t *testing.T) {
strategy := realis.JobUpdateFromAuroraTask(job.AuroraTask()). strategy := realis.JobUpdateFromAuroraTask(job.AuroraTask()).
VariableBatchStrategy(true, updateGroups...). VariableBatchStrategy(true, updateGroups...).
InstanceCount(6). InstanceCount(6).
WatchTime(1000) WatchTime(time.Second*1)
result, err := r.StartJobUpdate(strategy, "") result, err := r.StartJobUpdate(strategy, "")
require.NoError(t, err) require.NoError(t, err)