1 parent 2bbc819 commit 9afaebbCopy full SHA for 9afaebb
1 file changed
src/core/pipeline.py
@@ -1325,14 +1325,19 @@ def run(
1325
code = future_to_code[future]
1326
try:
1327
result = future.result()
1328
- if result:
+ if result and result.success:
1329
results.append(result)
1330
if single_stock_notify and send_notification and not dry_run:
1331
self._send_single_stock_notification(
1332
result,
1333
report_type=report_type,
1334
fallback_code=code,
1335
)
1336
+ elif result and not result.success:
1337
+ logger.warning(
1338
+ f"[{code}] 分析结果标记为失败,不计入汇总: "
1339
+ f"{result.error_message or '未知原因'}"
1340
+ )
1341
1342
# Issue #128: 分析间隔 - 在个股分析和大盘分析之间添加延迟
1343
if idx < len(stock_codes) - 1 and analysis_delay > 0:
0 commit comments