removed import of alternate tap module from unit-tests

src/bindings/python/flux/kvs.py

@@ -118,8 +118,21 @@ def __len__(self):
 
 
 
-
-
+@ffi.callback('KVSSetf')
+def KVSWatchWrapper(key, value, arg, errnum):
+  j = Jobj(handle = value)
+  (cb, real_arg) = ffi.from_handle(arg)
+  return cb(key, json.loads(j.as_str()), real_arg, errnum)
+
+kvswatches = {}
+def watch(flux_handle, key, fun, arg):
+  warg = (fun, arg)
+  kvswatches[key] = warg
+  return raw.watch(flux_handle, key, KVSWatchWrapper, ffi.new_handle(warg))
+
+def unwatch(flux_handle, key):
+  kvswatches.pop(key, None)
+  return raw.unwatch(flux_handle, key)
 
 
 

src/bindings/python/test/json_t.py

@@ -1,7 +1,6 @@
 import unittest
 import errno
 from flux.json_c import Jobj
-import tap
 
 json_str = '{ "a": 42 }'
 

src/bindings/python/test/request.py

@@ -2,7 +2,6 @@
 import errno
 import flux.core as core
 import flux.json_c
-import tap
 
 json_str = '{"a":42}';
 class TestRequestMethods(unittest.TestCase):