mirror of
https://github.com/simon987/hexlib.git
synced 2025-04-10 14:06:43 +00:00
Compare commits
3 Commits
b845d96295
...
f914759b71
Author | SHA1 | Date | |
---|---|---|---|
f914759b71 | |||
58d150279f | |||
b2efaa99a4 |
@ -160,6 +160,10 @@ def _sqlite_type(value):
|
||||
def _serialize(value):
|
||||
if isinstance(value, bytes):
|
||||
return base64.b64encode(value)
|
||||
if value is None:
|
||||
return None
|
||||
if isinstance(value, bool):
|
||||
return value
|
||||
return str(value)
|
||||
|
||||
|
||||
|
@ -11,13 +11,16 @@ last_time_called = dict()
|
||||
|
||||
def retry(attempts, callback=None):
|
||||
def decorate(func):
|
||||
retries = attempts
|
||||
while retries > 0:
|
||||
try:
|
||||
func()
|
||||
except Exception as e:
|
||||
if callback:
|
||||
callback(e)
|
||||
def wrapper(*args, **kwargs):
|
||||
retries = attempts
|
||||
while retries > 0:
|
||||
try:
|
||||
return func(*args, **kwargs)
|
||||
except Exception as e:
|
||||
if callback:
|
||||
callback(e)
|
||||
retries -= 1
|
||||
return wrapper
|
||||
return decorate
|
||||
|
||||
|
||||
|
2
setup.py
2
setup.py
@ -2,7 +2,7 @@ from setuptools import setup
|
||||
|
||||
setup(
|
||||
name="hexlib",
|
||||
version="1.20",
|
||||
version="1.23",
|
||||
description="Misc utility methods",
|
||||
author="simon987",
|
||||
author_email="me@simon987.net",
|
||||
|
@ -47,3 +47,31 @@ class TestPersistentState(TestCase):
|
||||
val["id"] = 1
|
||||
|
||||
self.assertDictEqual(val, s["a"][1])
|
||||
|
||||
def test_none(self):
|
||||
s = PersistentState()
|
||||
|
||||
val = {"a": 1, "b": None}
|
||||
s["a"][1] = val
|
||||
s["a"][1] = {
|
||||
"a": None
|
||||
}
|
||||
|
||||
val["a"] = None
|
||||
val["id"] = 1
|
||||
|
||||
self.assertDictEqual(val, s["a"][1])
|
||||
|
||||
def test_bool(self):
|
||||
s = PersistentState()
|
||||
|
||||
val = {"a": True, "b": False}
|
||||
s["a"][1] = val
|
||||
s["a"][1] = {
|
||||
"a": True
|
||||
}
|
||||
|
||||
val["a"] = True
|
||||
val["id"] = 1
|
||||
|
||||
self.assertDictEqual(val, s["a"][1])
|
||||
|
27
test/test_retry.py
Normal file
27
test/test_retry.py
Normal file
@ -0,0 +1,27 @@
|
||||
from unittest import TestCase
|
||||
from hexlib.db import VolatileState, VolatileBooleanState
|
||||
from hexlib.misc import retry
|
||||
|
||||
|
||||
class TestRetry(TestCase):
|
||||
|
||||
def test_simple(self):
|
||||
@retry(attempts=3)
|
||||
def a(i):
|
||||
return i + 1
|
||||
|
||||
self.assertEqual(a(1), 2)
|
||||
|
||||
def test_error(self):
|
||||
arr = []
|
||||
|
||||
def cb(e):
|
||||
arr.append(e)
|
||||
|
||||
@retry(attempts=3, callback=cb)
|
||||
def a(i):
|
||||
raise Exception("err")
|
||||
|
||||
a(1)
|
||||
|
||||
self.assertEqual(3, len(arr))
|
Loading…
x
Reference in New Issue
Block a user