.

wcfs/wcfs_test.py

@@ -35,7 +35,7 @@ from persistent.timestamp import TimeStamp
 import os, os.path, subprocess, threading
 from errno import EINVAL
 from golang import chan, func, defer, select
-from golang import context, sync
+from golang import context, sync, time
 from zodbtools.util import ashex as h, fromhex
 from pytest import raises
 from six import reraise
@@ -682,9 +682,8 @@ def watch(w, zf, at):   # XXX -> ?
     print('#  pinok: %s' % pinstr(pinok))
 
     # send watch request and check that we receive pins for in-cache blocks
-    # changed > at.
-    # XXX use timeout to detect wcfs replying less pins.
-    ctx, cancel = context.with_cancel(context.background())
+    # changed > at. Use timeout to detect wcfs replying less pins than expected.
+    ctx, cancel = context.with_timeout(context.background(), 3*time.second)
     wg = sync.WorkGroup(ctx)
 
     def _(ctx):