update

celery_stats/celery_stats_monitor.py

@@ -34,7 +34,7 @@ class Parse_data:
             len_data_diff = old_len_data - len_data
             rate = len_data_diff / per_sec
             if len_data_diff > 0:
-                use_time = round(len_data/rate/60/60,1)
+                use_time = round(len_data/rate/(60/per_sec)/60,1)
                 return "{} 目前{}队列中有{}条数据,预计{}小时后处理完成".format(time_ts,key_name,str(len_data),str(use_time))
             else:
                 if abs(rate) > 0: