diff --git a/main.py b/main.py index 36821f2e..73c53d44 100644 --- a/main.py +++ b/main.py @@ -27,8 +27,8 @@ schema = make_executable_schema(load_schema_from_path("schemas/core.graphql"), r async def start_up(): await redis.connect() - views_stat_task = asyncio.create_task(ViewedStorage().worker()) - print(views_stat_task) + # start viewed service + await ViewedStorage.init() if MODE == "development": # pid file management diff --git a/services/viewed.py b/services/viewed.py index 9aeeaf05..77e3bd32 100644 --- a/services/viewed.py +++ b/services/viewed.py @@ -72,6 +72,9 @@ class ViewedStorage: if token: self.client = create_client({"Authorization": f"Bearer {token}"}, schema=schema_str) print("[services.viewed] * authorized permanently by ackee.discours.io: %s" % token) + + views_stat_task = asyncio.create_task(self.worker()) + print(views_stat_task) else: print("[services.viewed] * please set ACKEE_TOKEN") self.disabled = True