Fix leastTimeout nano-ms conversion (#63)

livepeer · Mar 29, 2024 · babe9f0 · babe9f0
1 parent cfa43b3
commit babe9f0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/api.go b/api.go
@@ -910,13 +910,13 @@ func (lapi *Client) Heartbeat(id string) error {
 }
 
 // LockPull locks the stream pull
-func (lapi *Client) LockPull(id string, leaseTimeoutMs time.Duration, host string) error {
+func (lapi *Client) LockPull(id string, leaseTimeout time.Duration, host string) error {
 	if id == "" {
 		return errors.New("empty id")
 	}
 
 	payload := map[string]interface{}{
-		"leaseTimeout": leaseTimeoutMs,
+		"leaseTimeout": leaseTimeout.Milliseconds(),
 		"host":         host,
 	}
 	u := fmt.Sprintf("%s/api/stream/%s/lockPull", lapi.chosenServer, id)