diff --git a/smart_kit/start_points/main_loop_kafka.py b/smart_kit/start_points/main_loop_kafka.py index b8ed445f..616d99a0 100644 --- a/smart_kit/start_points/main_loop_kafka.py +++ b/smart_kit/start_points/main_loop_kafka.py @@ -799,3 +799,8 @@ def _stats_for_outgoing(self, user: User): key="inner_stats", default=[] )) callback.action_params.setdefault("stats_system", callback.behavior_id) + user.mid_variables.update( + key="inner_stats", + value=[stats if isinstance(stats, dict) else stats.toJSON() + for stats in user.mid_variables.get(key="inner_stats", default=[])] + )