File tree Expand file tree Collapse file tree
lib/iris/src/iris/cluster/controller Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1276,17 +1276,24 @@ def __init__(
12761276 k8s_provider = self ._provider
12771277 k8s_log_client = LogClient .connect (self ._log_service_address , interceptors = log_client_interceptors )
12781278 k8s_provider .log_client = k8s_log_client
1279+
1280+ def _install_k8s_task_stats_table (table : Table ) -> None :
1281+ k8s_provider .task_stats_table = table
1282+
1283+ def _install_k8s_profile_table (table : Table ) -> None :
1284+ k8s_provider .profile_table = table
1285+
12791286 k8s_provider .task_stats_table = self ._register_finelog_table (
12801287 k8s_log_client ,
12811288 TASK_STATS_NAMESPACE ,
12821289 IrisTaskStat ,
1283- on_late_success = lambda t : setattr ( k8s_provider , "task_stats_table" , t ) ,
1290+ on_late_success = _install_k8s_task_stats_table ,
12841291 )
12851292 k8s_provider .profile_table = self ._register_finelog_table (
12861293 k8s_log_client ,
12871294 PROFILE_NAMESPACE ,
12881295 IrisProfile ,
1289- on_late_success = lambda t : setattr ( k8s_provider , "profile_table" , t ) ,
1296+ on_late_success = _install_k8s_profile_table ,
12901297 )
12911298
12921299 # Controller process logs ship to the log server via RemoteLogHandler.
You can’t perform that action at this time.
0 commit comments