diff --git a/examples/cached_alias_config.py b/examples/cached_alias_config.py index a22678ad..8ad82f08 100644 --- a/examples/cached_alias_config.py +++ b/examples/cached_alias_config.py @@ -51,7 +51,7 @@ async def alt_cache(): await cache.close() -async def test_alias(): +async def main() -> None: await default_cache() await alt_cache() @@ -63,4 +63,4 @@ async def test_alias(): if __name__ == "__main__": - asyncio.run(test_alias()) + asyncio.run(main()) diff --git a/examples/cached_decorator.py b/examples/cached_decorator.py index 72c53550..c66732c0 100644 --- a/examples/cached_decorator.py +++ b/examples/cached_decorator.py @@ -15,7 +15,7 @@ async def cached_call(): return Result("content", 200) -async def test_cached(): +async def main() -> None: async with Cache(Cache.REDIS, endpoint="127.0.0.1", port=6379, namespace="main") as cache: await cached_call() exists = await cache.exists("key") @@ -24,4 +24,4 @@ async def test_cached(): if __name__ == "__main__": - asyncio.run(test_cached()) + asyncio.run(main()) diff --git a/examples/marshmallow_serializer_class.py b/examples/marshmallow_serializer_class.py index 5fd233c3..0a1c4129 100644 --- a/examples/marshmallow_serializer_class.py +++ b/examples/marshmallow_serializer_class.py @@ -54,10 +54,10 @@ async def serializer(): assert result.list_type == model.list_type -async def test_serializer(): +async def main() -> None: await serializer() await cache.delete("key") if __name__ == "__main__": - asyncio.run(test_serializer()) + asyncio.run(main()) diff --git a/examples/multicached_decorator.py b/examples/multicached_decorator.py index d05d5f4a..32d6e866 100644 --- a/examples/multicached_decorator.py +++ b/examples/multicached_decorator.py @@ -23,7 +23,7 @@ async def multi_cached_keys(keys=None): cache = Cache(Cache.REDIS, endpoint="127.0.0.1", port=6379, namespace="main") -async def test_multi_cached(): +async def main() -> None: await multi_cached_ids(ids=("a", "b")) await multi_cached_ids(ids=("a", "c")) await multi_cached_keys(keys=("d",)) @@ -41,4 +41,4 @@ async def test_multi_cached(): if __name__ == "__main__": - asyncio.run(test_multi_cached()) + asyncio.run(main()) diff --git a/examples/optimistic_lock.py b/examples/optimistic_lock.py index 20624907..0f771318 100644 --- a/examples/optimistic_lock.py +++ b/examples/optimistic_lock.py @@ -36,11 +36,11 @@ async def concurrent(): await asyncio.gather(my_view(), my_view(), my_view()) -async def test_redis(): +async def main() -> None: await concurrent() await cache.delete("key") await cache.close() if __name__ == '__main__': - asyncio.run(test_redis()) + asyncio.run(main()) diff --git a/examples/plugins.py b/examples/plugins.py index b870d82b..e644b937 100644 --- a/examples/plugins.py +++ b/examples/plugins.py @@ -46,7 +46,7 @@ async def run(): print(cache.profiling) -async def test_run(): +async def main() -> None: await run() await cache.delete("a") await cache.delete("b") @@ -55,4 +55,4 @@ async def test_run(): if __name__ == "__main__": - asyncio.run(test_run()) + asyncio.run(main()) diff --git a/examples/python_object.py b/examples/python_object.py index 8eea8b3b..c1971c1d 100644 --- a/examples/python_object.py +++ b/examples/python_object.py @@ -18,11 +18,11 @@ async def complex_object(): assert my_object.y == 2 -async def test_python_object(): +async def main() -> None: await complex_object() await cache.delete("key") await cache.close() if __name__ == "__main__": - asyncio.run(test_python_object()) + asyncio.run(main()) diff --git a/examples/redlock.py b/examples/redlock.py index e763ddb3..466d62c4 100644 --- a/examples/redlock.py +++ b/examples/redlock.py @@ -32,11 +32,11 @@ async def concurrent(): await asyncio.gather(my_view(), my_view(), my_view()) -async def test_redis(): +async def main() -> None: await concurrent() await cache.delete("key") await cache.close() if __name__ == '__main__': - asyncio.run(test_redis()) + asyncio.run(main()) diff --git a/examples/run_all.sh b/examples/run_all.sh index aa8049e9..9264faa2 100755 --- a/examples/run_all.sh +++ b/examples/run_all.sh @@ -4,8 +4,12 @@ pushd "$(dirname "$0")" for f in `find . -name '*.py' -not -path "./frameworks/*"`; do echo "########## Running $f #########" - python $f || exit 1 - echo;echo;echo + # ResourceWarning in __del__ fails to exit 1, so we grep for warnings. + # Did try using sys.unraisablehook, but it wasn't working. + python -bb -We -X dev $f 2>&1 | tee /dev/stderr | ( ! fgrep -i 'warning' > /dev/null ) || exit 1 + if [ ${PIPESTATUS[0]} -ne 0 ]; then + exit 1 + fi done popd diff --git a/examples/serializer_class.py b/examples/serializer_class.py index 50562b12..d5912a36 100644 --- a/examples/serializer_class.py +++ b/examples/serializer_class.py @@ -15,11 +15,11 @@ class CompressionSerializer(BaseSerializer): def dumps(self, value): print("I've received:\n{}".format(value)) compressed = zlib.compress(value.encode()) - print("But I'm storing:\n{}".format(compressed)) + print("But I'm storing:\n{!r}".format(compressed)) return compressed def loads(self, value): - print("I've retrieved:\n{}".format(value)) + print("I've retrieved:\n{!r}".format(value)) decompressed = zlib.decompress(value).decode() print("But I'm returning:\n{}".format(decompressed)) return decompressed @@ -43,11 +43,11 @@ async def serializer(): assert len(compressed_value) < len(real_value.encode()) -async def test_serializer(): +async def main() -> None: await serializer() await cache.delete("key") await cache.close() if __name__ == "__main__": - asyncio.run(test_serializer()) + asyncio.run(main()) diff --git a/examples/serializer_function.py b/examples/serializer_function.py index affa0b3b..4cfc477d 100644 --- a/examples/serializer_function.py +++ b/examples/serializer_function.py @@ -42,11 +42,11 @@ async def serializer_function(): assert json.loads(await cache.raw("get", "main:key")) == {"y": 2.0, "x": 1.0} -async def test_serializer_function(): +async def main() -> None: await serializer_function() await cache.delete("key") await cache.close() if __name__ == "__main__": - asyncio.run(test_serializer_function()) + asyncio.run(main()) diff --git a/examples/simple_redis.py b/examples/simple_redis.py index 2ff6278d..87faede3 100644 --- a/examples/simple_redis.py +++ b/examples/simple_redis.py @@ -15,7 +15,7 @@ async def redis(): assert await cache.raw("ttl", "main:expire_me") > 0 -async def test_redis(): +async def main() -> None: await redis() await cache.delete("key") await cache.delete("expire_me") @@ -23,4 +23,4 @@ async def test_redis(): if __name__ == "__main__": - asyncio.run(test_redis()) + asyncio.run(main())