foramt code

applications/tasks/analysis_task/account_position_info.py

@@ -543,7 +543,9 @@ class AccountPositionOpenRateAvg(AccountPositionReadRateAvg):
             where gh_id = %s and update_time = %s;
         """
         return await self.pool.async_save(
-            query=update_query, db_name="piaoquan_crawler", params=(avg_read_rate, gh_id, date_string)
+            query=update_query,
+            db_name="piaoquan_crawler",
+            params=(avg_read_rate, gh_id, date_string),
         )
 
     async def deal(self, date_string: str | None):

applications/tasks/data_recycle_tasks/recycle_daily_publish_articles.py

@@ -38,7 +38,7 @@ class Const:
         "gh_93e00e187787",
         "gh_080bb43aa0dc",
         "gh_b1c71a0e7a85",
-        "gh_d5f935d0d1f2"
+        "gh_d5f935d0d1f2",
     ]
 
     # NOT USED SERVER ACCOUNT

applications/tasks/task_handler.py

@@ -259,7 +259,7 @@ class TaskHandler(TaskMapper):
         await task.deal(end_date=self.data.get("end_date"))
         return self.TASK_SUCCESS_STATUS
 
-     # 更新账号阅读均值
+    # 更新账号阅读均值
     async def _update_account_read_avg_handler(self) -> int:
         task = AccountPositionReadAvg(
             pool=self.db_client, log_client=self.log_client, trace_id=self.trace_id