4
main.py
4
main.py
@@ -27,8 +27,8 @@ schema = make_executable_schema(load_schema_from_path("schemas/core.graphql"), r
|
|||||||
async def start_up():
|
async def start_up():
|
||||||
await redis.connect()
|
await redis.connect()
|
||||||
|
|
||||||
views_stat_task = asyncio.create_task(ViewedStorage().worker())
|
# start viewed service
|
||||||
print(views_stat_task)
|
await ViewedStorage.init()
|
||||||
|
|
||||||
if MODE == "development":
|
if MODE == "development":
|
||||||
# pid file management
|
# pid file management
|
||||||
|
|||||||
@@ -72,6 +72,9 @@ class ViewedStorage:
|
|||||||
if token:
|
if token:
|
||||||
self.client = create_client({"Authorization": f"Bearer {token}"}, schema=schema_str)
|
self.client = create_client({"Authorization": f"Bearer {token}"}, schema=schema_str)
|
||||||
print("[services.viewed] * authorized permanently by ackee.discours.io: %s" % token)
|
print("[services.viewed] * authorized permanently by ackee.discours.io: %s" % token)
|
||||||
|
|
||||||
|
views_stat_task = asyncio.create_task(self.worker())
|
||||||
|
print(views_stat_task)
|
||||||
else:
|
else:
|
||||||
print("[services.viewed] * please set ACKEE_TOKEN")
|
print("[services.viewed] * please set ACKEE_TOKEN")
|
||||||
self.disabled = True
|
self.disabled = True
|
||||||
|
|||||||
Reference in New Issue
Block a user