started-log
This commit is contained in:
2
main.py
2
main.py
@@ -46,6 +46,8 @@ async def start_up():
|
|||||||
print("[sentry] init error")
|
print("[sentry] init error")
|
||||||
print(e)
|
print(e)
|
||||||
|
|
||||||
|
print("[main] started")
|
||||||
|
|
||||||
|
|
||||||
async def dev_start_up():
|
async def dev_start_up():
|
||||||
if exists(DEV_SERVER_PID_FILE_NAME):
|
if exists(DEV_SERVER_PID_FILE_NAME):
|
||||||
|
|||||||
@@ -13,8 +13,9 @@ class RedisCache:
|
|||||||
self._instance = aredis.StrictRedis.from_url(self._uri, decode_responses=True)
|
self._instance = aredis.StrictRedis.from_url(self._uri, decode_responses=True)
|
||||||
|
|
||||||
async def disconnect(self):
|
async def disconnect(self):
|
||||||
self._instance.connection_pool.disconnect()
|
if self._instance:
|
||||||
self._instance = None
|
self._instance.connection_pool.disconnect()
|
||||||
|
self._instance = None
|
||||||
|
|
||||||
async def execute(self, command, *args, **kwargs):
|
async def execute(self, command, *args, **kwargs):
|
||||||
while not self._instance:
|
while not self._instance:
|
||||||
|
|||||||
Reference in New Issue
Block a user