Add missing lock file

chaind/adapters/fs.py

@@ -90,19 +90,12 @@ class ChaindFsAdapter(ChaindAdapter):
     def succeed(self, block, tx):
         if self.store.is_reserved(tx.hash):
             raise QueueLockError(tx.hash)
-        r = self.store.final(tx.hash, block, tx, error=False)
-        (k, v) = self.store.get(tx.hash)
-        self.store.purge(k)
-        return r
+
+        return self.store.final(tx.hash, block, tx, error=False)
 
 
     def fail(self, block, tx):
-        if self.store.is_reserved(tx.hash):
-            raise QueueLockError(tx.hash)
-        r = self.store.final(tx.hash, block, tx, error=True)
-        (k, v) = self.store.get(tx.hash)
-        self.store.purge(k)
-        return r
+        return self.store.final(tx.hash, block, tx, error=True)
 
 
     def sendfail(self):

chaind/unittest/common.py

@@ -29,6 +29,8 @@ class MockDispatcher:
 
 
     def send(self, v):
+        import sys
+        sys.stderr.write('susu v {} {}\n'.format(v, self.fails))
         if v in self.fails:
             raise RPCException('{} is in fails'.format(v))
         pass

requirements.txt

@@ -1,5 +1,5 @@
 chainlib~=0.1.1
-chainqueue~=0.1.9
+chainqueue~=0.1.8
 chainsyncer~=0.4.3
 confini~=0.6.0
 funga~=0.5.2

setup.cfg

@@ -1,6 +1,6 @@
 [metadata]
 name = chaind
-version = 0.2.3
+version = 0.2.2
 description = Base package for chain queue service
 author = Louis Holbrook
 author_email = dev@holbrook.no