fix checking of context error

2017-09-01 09:53:09 -07:00 · 2017-09-01 09:53:09 -07:00 · 26e66ed1c5
parent 4cc8bac48d
commit 26e66ed1c5
1 changed files with 1 additions and 1 deletions
--- a/nomad/rpc.go
+++ b/nomad/rpc.go
@ -397,7 +397,7 @@ RUN_QUERY:

 	// Check for minimum query time
 	if err == nil && opts.queryOpts.MinQueryIndex > 0 && opts.queryMeta.Index <= opts.queryOpts.MinQueryIndex {
-		if expired := ws.WatchCtx(ctx); !expired {
+		if err := ws.WatchCtx(ctx); err == nil {
 			goto RUN_QUERY
 		}
 	}