From fe676ab599b1f211ba322ec3f934b0c026a566ed Mon Sep 17 00:00:00 2001 From: khushal Date: Thu, 12 Dec 2024 11:53:02 +0530 Subject: [PATCH] (20241212) Added tests to check if everything is up and running. --- tests/kafka_test.py | 2 +- .../__pycache__/__init__.cpython-310.pyc | Bin 168 -> 164 bytes .../async_redis_cache.cpython-310.pyc | Bin 13364 -> 13364 bytes .../__pycache__/__init__.cpython-310.pyc | Bin 171 -> 167 bytes .../async_mongo_v2.cpython-310.pyc | Bin 40273 -> 40265 bytes .../__pycache__/__init__.cpython-310.pyc | Bin 186 -> 165 bytes .../string/__pycache__/json.cpython-310.pyc | Bin 3563 -> 3542 bytes .../__pycache__/__init__.cpython-310.pyc | Bin 186 -> 165 bytes .../system/__pycache__/files.cpython-310.pyc | Bin 11571 -> 11550 bytes 9 files changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/kafka_test.py b/tests/kafka_test.py index 98c1936..478a5b3 100644 --- a/tests/kafka_test.py +++ b/tests/kafka_test.py @@ -134,7 +134,7 @@ if __name__ == "__main__": while True: await asyncio.sleep(1.0) messages = await my_consumer.consume(count = 10, timeout = 1.0) - for message in messages: print(json.to_string(message["value"])) + for message in messages: print("MESSAGE:", json.to_string(message["value"])) async def main(): await asyncio.gather(*[keep_producing(), keep_consuming()]) diff --git a/utils_v2/cache/__pycache__/__init__.cpython-310.pyc b/utils_v2/cache/__pycache__/__init__.cpython-310.pyc index b168cc850596affdce0ed0cd7af9dc4af6a49b13..63bfb606830039e6ddf12554c329ed5729ff756b 100644 GIT binary patch delta 36 qcmZ3%xP*~ApO=@50SNxqM@{6mVRWD9p~8`wSCU$kmzXoL!Tb82r;!zzqXOLnw2qRawn?_Phxs{d`fMv>$>y!BOxBFQ oCi_@^nJj1IxA~W2J>z77cH7OCpkYiz96wOH#M&$J~1yP LzBspdVu>LD?TZs# diff --git a/utils_v2/string/__pycache__/json.cpython-310.pyc b/utils_v2/string/__pycache__/json.cpython-310.pyc index 4d899fcd6c0555a254a73ee5fa512b0f6171e121..00bccbc41dac84b1c6e9b56c9b17ddb6de1e7803 100644 GIT binary patch delta 40 ucmaDYeNCD>pO=@50SNxqM{VR5WM*`kEX%CIk(pPLT9lWVvpJ5rmkR*k01IdU delta 61 zcmca6{aTtkpO=@50SMOJ_TR`Y$jlfyS(aHvHY2krF)uT|BsC{FKR3Q0u`)L`uOvP( PFD1S>w|KKBb1xSFI~Noo diff --git a/utils_v2/system/__pycache__/__init__.cpython-310.pyc b/utils_v2/system/__pycache__/__init__.cpython-310.pyc index aec6600212e369703f5dddc7f9abc2757833de82..ba0ab2c08e35b93e82a81a6eb34cf6f80fd31057 100644 GIT binary patch delta 36 qcmdnRxRjAQpO=@50SNxqM@{6mVf2{jp~8`wSCU$kmzXoL(+~ixLJFh+ delta 57 zcmZ3=xQmfHpO=@50SMOJ_MgaY!x%f!Lq#?tvnVkyGrlA>CpkYiz96wOH#M&$J~1yP LzBspdVu>LD?TZs# diff --git a/utils_v2/system/__pycache__/files.cpython-310.pyc b/utils_v2/system/__pycache__/files.cpython-310.pyc index 76fd4c4ec55691fb842555259cdbcf5c39628e13..edaa3cf2d5ee9813d7c2f930f7a79ec83362c43f 100644 GIT binary patch delta 40 ucmdlSH7|-gpO=@50SNxqM{VRj!NTY|`3j2)M`m70YEfQd&Sp_oISl~&-waOx delta 60 zcmbOiwK%yps6D Oyp;Ij+~Q5FavA_(pcMxI