|
|
@@ -1277,6 +1277,14 @@ async def reconcile_traces():
|
|
|
result_summary="[Reconciliation] 任务由于服务重启或异常中断已自动停止。"
|
|
|
)
|
|
|
count += 1
|
|
|
+
|
|
|
+ if _application_runtime is not None:
|
|
|
+ try:
|
|
|
+ await _application_runtime.reconcile_all_events()
|
|
|
+ except Exception:
|
|
|
+ logger.exception(
|
|
|
+ "[Reconciliation] Application run-event reconciliation failed"
|
|
|
+ )
|
|
|
|
|
|
if count > 0:
|
|
|
logger.info(f"[Reconciliation] Successfully reconciled {count} traces.")
|