diff options
| author | VG <vg@devys.org> | 2016-04-11 17:53:55 +0200 |
|---|---|---|
| committer | VG <vg@devys.org> | 2016-04-11 17:53:55 +0200 |
| commit | c68ac4fb82b55f4ea6fcc28b4cef5f7ee38db238 (patch) | |
| tree | 2a0cdbb614990259a7bf6b76346995dba8df2e52 /src | |
| parent | 4b59cc343e88cff459bc663bbc85e3c701fdd415 (diff) | |
| download | wqueue-c68ac4fb82b55f4ea6fcc28b4cef5f7ee38db238.tar.gz wqueue-c68ac4fb82b55f4ea6fcc28b4cef5f7ee38db238.tar.bz2 wqueue-c68ac4fb82b55f4ea6fcc28b4cef5f7ee38db238.zip | |
Auto-commit on 6d1dbe8495b5fafbc5f50d80268d0ca5b7b097be
Diffstat (limited to 'src')
| -rwxr-xr-x | src/wqueue2.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/wqueue2.py b/src/wqueue2.py index 4c2cd4c..f60f947 100755 --- a/src/wqueue2.py +++ b/src/wqueue2.py @@ -13,7 +13,7 @@ import collections u8open = functools.partial(open, encoding='utf8') -class PersistentQueue3: +class PersistentQueue: def __init__(self, filename=None): self.queue = collections.deque() @@ -98,7 +98,7 @@ async def manage_client(reader, writer): async def jobs_runner(): - jobs = PersistentQueue3(filename='queue.txt') + jobs = PersistentQueue(filename='queue.txt') queue = [] while True: job = await jobs.get_job() |