Method set_variable

backend/app/executors/base.py:409–482

设置变量值

(self, name: str, value: Any)

        return self.variables.get(name, default)
    
    def set_variable(self, name: str, value: Any):
        """设置变量值"""
        import json
        from datetime import datetime
        
        # 记录旧值
        old_value = self.variables.get(name)
        
        # 设置新值
        self.variables[name] = value
        
        # 记录变量追踪信息
        try:
            # 尝试序列化值用于显示
            def serialize_value(v):
                if v is None:
                    return None
                elif isinstance(v, (str, int, float, bool)):
                    return v
                elif isinstance(v, (list, dict)):
                    try:
                        # 尝试JSON序列化
                        json.dumps(v)
                        return v
                    except Exception:
                        return str(v)
                else:
                    return str(v)
            
            tracking_record = {
                "timestamp": datetime.now().isoformat(),
                "variable_name": name,
                "old_value": serialize_value(old_value),
                "new_value": serialize_value(value),
                "node_id": self._current_node_id,
                "node_name": self._current_node_name or "未知模块",
                "operation": "create" if old_value is None else "update",
                "value_type": type(value).__name__
            }
            # 限制追踪记录数量上限，防止长循环导致内存爆炸
            _MAX_TRACKING = 5000
            self._variable_tracking.append(tracking_record)
            if len(self._variable_tracking) > _MAX_TRACKING:
                # 删除最早的 1/4 记录（避免每次都做截断的开销）
                drop = _MAX_TRACKING // 4
                del self._variable_tracking[:drop]
        except Exception as e:
            print(f"记录变量追踪失败: {e}")
        
        # 通知变量更新
        if self._variable_update_callback:
            import asyncio
            try:
                # 在异步上下文中调用回调（仅当存在运行中的事件循环）
                try:
                    asyncio.get_running_loop()
                    # 保存任务引用避免被 GC，并通过 done_callback 处理异常
                    task = asyncio.create_task(self._variable_update_callback(name, value))