From ca4f7c9b8ec6c951cdadb6ea4bc8b63ff3467ca7 Mon Sep 17 00:00:00 2001 From: nolash Date: Tue, 1 Jun 2021 13:53:44 +0200 Subject: [PATCH] Rename fs queue controller module --- chainqueue/fs/{cache.py => queue.py} | 5 ++++- tests/test_fs.py | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) rename chainqueue/fs/{cache.py => queue.py} (97%) diff --git a/chainqueue/fs/cache.py b/chainqueue/fs/queue.py similarity index 97% rename from chainqueue/fs/cache.py rename to chainqueue/fs/queue.py index 2ccd395..8daf9a8 100644 --- a/chainqueue/fs/cache.py +++ b/chainqueue/fs/queue.py @@ -45,6 +45,8 @@ class FsQueue: self.path_state[r[0]] = r[1] self.index_path = os.path.join(self.path, '.active') + self.nonce_path = os.path.join(self.path, '.accounts') + os.makedirs(self.index_path, exist_ok=True) @@ -100,7 +102,8 @@ class FsQueue: os.unlink(cur_path) logg.debug('purge queue entry {}'.format(key_hex)) - + + def set(self, key, status): idx = self.__get_backend_idx(key) diff --git a/tests/test_fs.py b/tests/test_fs.py index 02f8862..a80e4d9 100644 --- a/tests/test_fs.py +++ b/tests/test_fs.py @@ -6,7 +6,7 @@ import logging import os # local imports -from chainqueue.fs.cache import FsQueue +from chainqueue.fs.queue import FsQueue from chainqueue.fs.dir import HexDir from chainqueue.enum import StatusBits