File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -349,7 +349,9 @@ def do_data_transfer(self):
349349 """
350350
351351 consecutive_error_count = 0
352- max_errors = envs .FD_CACHE_PROC_ERROR_COUNT # 连续错误超过此次数后检测work进程是否还存在
352+ max_errors = (
353+ envs .FD_CACHE_PROC_ERROR_COUNT
354+ ) # After this many consecutive errors, check if the worker process exists.
353355
354356 while True :
355357 try :
@@ -405,8 +407,8 @@ def do_data_transfer(self):
405407 consecutive_error_count = 0
406408
407409 except (BrokenPipeError , EOFError , ConnectionResetError ) as e :
408- # cache_transfer_manager进程残留时会持续打印异常日志导致磁盘耗尽,此处增加检测work进程是否存活,
409- # 如果worker进程已经结束,此残留进程会终止循环退出,避免持续打印异常日志
410+ # When a cache_transfer_manager process remains, it keeps printing error logs and may exhaust disk space.
411+ # Add a check to see if the worker process is alive; if it has ended, exit the loop to stop continuous logging.
410412 logger .error (f"[CacheTransferManager] Connection broken: { e } " )
411413 consecutive_error_count += 1
412414 if consecutive_error_count > max_errors :
You can’t perform that action at this time.
0 commit comments