Run examples with warnings

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())

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())

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())

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())

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())

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())

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())

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())

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

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())

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())

examples/simple_redis.py

@@ -15,12 +15,12 @@ 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")
     await cache.close()
 
 
 if __name__ == "__main__":
-    asyncio.run(test_redis())
+    asyncio.run(main())