feat: Add logging to all examples

lablup · Sep 12, 2023 · 1f23cbd · 1f23cbd
1 parent 897381f
commit 1f23cbd
Show file tree

Hide file tree

Showing 11 changed files with 61 additions and 1 deletion.
diff --git a/examples/ordering-by-exit-server.py b/examples/ordering-by-exit-server.py
@@ -1,5 +1,6 @@
 import asyncio
 import json
+import logging
 import signal
 
 from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
@@ -61,4 +62,9 @@ async def serve():
 
 
 if __name__ == "__main__":
+    logging.basicConfig(
+        format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
+        level=logging.INFO,
+    )
+    log = logging.getLogger()
     asyncio.run(serve())
diff --git a/examples/ordering-by-key-server.py b/examples/ordering-by-key-server.py
@@ -1,5 +1,6 @@
 import asyncio
 import json
+import logging
 import signal
 
 from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
@@ -61,4 +62,9 @@ async def serve() -> None:
 
 
 if __name__ == "__main__":
+    logging.basicConfig(
+        format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
+        level=logging.INFO,
+    )
+    log = logging.getLogger()
     asyncio.run(serve())
diff --git a/examples/ordering-client.py b/examples/ordering-client.py
@@ -1,5 +1,6 @@
 import asyncio
 import json
+import logging
 
 from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
 from callosum.rpc import Peer
@@ -38,4 +39,9 @@ async def call() -> None:
 
 
 if __name__ == "__main__":
+    logging.basicConfig(
+        format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
+        level=logging.INFO,
+    )
+    log = logging.getLogger()
     asyncio.run(call())
diff --git a/examples/simple-client-redis.py b/examples/simple-client-redis.py
@@ -1,5 +1,6 @@
 import asyncio
 import json
+import logging
 import os
 import random
 import secrets
@@ -51,4 +52,9 @@ async def call():
 
 
 if __name__ == "__main__":
+    logging.basicConfig(
+        format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
+        level=logging.INFO,
+    )
+    log = logging.getLogger()
     asyncio.run(call())
diff --git a/examples/simple-client-thrift.py b/examples/simple-client-thrift.py
@@ -1,4 +1,5 @@
 import asyncio
+import logging
 import pathlib
 import random
 import secrets
@@ -69,4 +70,9 @@ async def call() -> None:
 
 
 if __name__ == "__main__":
+    logging.basicConfig(
+        format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
+        level=logging.INFO,
+    )
+    log = logging.getLogger()
     asyncio.run(call())
diff --git a/examples/simple-client.py b/examples/simple-client.py
@@ -162,7 +162,7 @@ async def multi_clients() -> None:
 if __name__ == "__main__":
     logging.basicConfig(
         format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
-        level=logging.DEBUG,
+        level=logging.INFO,
     )
     log = logging.getLogger()
 

diff --git a/examples/simple-consumer-redis.py b/examples/simple-consumer-redis.py
@@ -7,6 +7,7 @@
 """
 import asyncio
 import json
+import logging
 import os
 import signal
 
@@ -63,4 +64,9 @@ async def consume() -> None:
 
 
 if __name__ == "__main__":
+    logging.basicConfig(
+        format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
+        level=logging.INFO,
+    )
+    log = logging.getLogger()
     asyncio.run(consume())
diff --git a/examples/simple-publisher-redis.py b/examples/simple-publisher-redis.py
@@ -5,6 +5,7 @@
 """
 import asyncio
 import json
+import logging
 import os
 import random
 import secrets
@@ -52,4 +53,9 @@ async def addition_event(addend1: int, addend2: int):
 
 
 if __name__ == "__main__":
+    logging.basicConfig(
+        format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
+        level=logging.INFO,
+    )
+    log = logging.getLogger()
     asyncio.run(publish())
diff --git a/examples/simple-server-redis.py b/examples/simple-server-redis.py
@@ -1,5 +1,6 @@
 import asyncio
 import json
+import logging
 import os
 import signal
 import time
@@ -54,4 +55,9 @@ async def serve() -> None:
 
 
 if __name__ == "__main__":
+    logging.basicConfig(
+        format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
+        level=logging.INFO,
+    )
+    log = logging.getLogger()
     asyncio.run(serve())
diff --git a/examples/simple-server-thrift.py b/examples/simple-server-thrift.py
@@ -1,4 +1,5 @@
 import asyncio
+import logging
 import pathlib
 import signal
 
@@ -55,4 +56,9 @@ async def serve() -> None:
 
 
 if __name__ == "__main__":
+    logging.basicConfig(
+        format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
+        level=logging.INFO,
+    )
+    log = logging.getLogger()
     asyncio.run(serve())
diff --git a/examples/simple-server.py b/examples/simple-server.py
@@ -1,5 +1,6 @@
 import asyncio
 import json
+import logging
 import signal
 import sys
 import tracemalloc
@@ -153,4 +154,9 @@ def main(scheduler_type):
 
 
 if __name__ == "__main__":
+    logging.basicConfig(
+        format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
+        level=logging.INFO,
+    )
+    log = logging.getLogger()
     main()