Fix time arithmetic

Greg Russell · Greg Russell · commit e1bf41180c89 · 2017-10-16T23:44:35.000-04:00
diff --git a/bq/insert.go b/bq/insert.go
@@ -263,7 +263,8 @@ func (in *BQInserter) Flush() error {
 		}
 		metrics.WarningCount.WithLabelValues(in.TableBase(), "", "Quota Exceeded").Inc()
 		// Use some randomness to reduce risk of synchronization across tasks.
-		time.Sleep(time.Seconds((0.5 + rand.Float64()) * in.params.RetryDelay.Seconds()))
+		t := in.params.RetryDelay.Seconds() * (0.5 + rand.Float64()) // between 0.5 and 1.5 * RetryDelay
+		time.Sleep(time.Duration(1000000*t) * time.Microsecond)
 	}
 
 	// If there is still an error, then handle it.

Original file line number	Diff line number	Diff line change
`@@ -263,7 +263,8 @@ func (in *BQInserter) Flush() error {`
`263`	`263`	`}`
`264`	`264`	`metrics.WarningCount.WithLabelValues(in.TableBase(), "", "Quota Exceeded").Inc()`
`265`	`265`	`// Use some randomness to reduce risk of synchronization across tasks.`
`266`		`- time.Sleep(time.Seconds((0.5 + rand.Float64()) * in.params.RetryDelay.Seconds()))`
	`266`	`+ t := in.params.RetryDelay.Seconds() * (0.5 + rand.Float64()) // between 0.5 and 1.5 * RetryDelay`
	`267`	`+ time.Sleep(time.Duration(1000000t) time.Microsecond)`
`267`	`268`	`}`
`268`	`269`
`269`	`270`	`// If there is still an error, then handle it.`