feat: 优化工作流日志记录逻辑

FHU-yezi · Nov 11, 2024 · 3b8da07 · 3b8da07
1 parent 6bc9aff
commit 3b8da07
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/jobs/jianshu/article_earning_ranking.py b/jobs/jianshu/article_earning_ranking.py
@@ -22,7 +22,7 @@
 )
 
 
-@retry(attempts=5, delay=10)
+@retry(attempts=3, delay=5)
 async def get_author_slug_and_info(
     item: RecordField,
 ) -> tuple[Optional[str], Optional[UserInfo]]:

diff --git a/utils/log.py b/utils/log.py
@@ -16,17 +16,14 @@ def get_flow_run_name() -> str:
     return runtime.flow_run.name  # type: ignore
 
 
-def log_flow_run_start(logger: Logger) -> str:
+def log_flow_run_start(logger: Logger) -> None:
     logger.info(
         "开始执行工作流",
         flow_run_name=runtime.flow_run.name,  # type: ignore
         flow_name=runtime.flow_run.flow_name,  # type: ignore
         deployment_name=runtime.deployment.name,  # type: ignore
     )
 
-    # 返回流程运行名称，供后续日志使用
-    return get_flow_run_name()  # type: ignore
-
 
 def log_flow_run_success(logger: Logger, **kwargs: ExtraType) -> None:
     logger.info(