File size: 2,015 Bytes
101858b | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 | from __future__ import annotations
from dataclasses import dataclass
from typing import Any, Dict, Optional
import torch
from .shared_model import SharedBackboneAdapter, get_shared_adapter, register_shared_model
@dataclass
class SharedSystems:
adapter: SharedBackboneAdapter
consciousness: Optional[Any] = None
agi_memory: Optional[Any] = None
errors: Optional[Dict[str, str]] = None
def initialize_shared_systems(
model,
tokenizer=None,
*,
enable_consciousness: bool = True,
enable_agi_memory: bool = True,
) -> SharedSystems:
adapter = register_shared_model(model, tokenizer)
errors: Dict[str, str] = {}
consciousness = None
agi_memory = None
if enable_consciousness:
try:
from ConsciousnessSystem.config import ConsciousnessSystemConfig
from ConsciousnessSystem.consciousness_system import ConsciousnessSystem
cfg = ConsciousnessSystemConfig(
device=str(adapter.device),
hidden_dim=adapter.hidden_size,
use_fp16=adapter.dtype in (torch.float16, torch.bfloat16),
)
consciousness = ConsciousnessSystem(cfg, qwen_model=model)
except Exception as exc:
errors["consciousness"] = str(exc)
if enable_agi_memory:
try:
from agi_memory.core import AGIMemoryConfig, AGIMemorySystem
cfg = AGIMemoryConfig(
device=adapter.device,
use_fp16=adapter.dtype in (torch.float16, torch.bfloat16),
disable_vae_compression=True,
enable_rag=False,
enable_dynamic_action=False,
enable_neuro_fusion=False,
enable_memory_optimization=False,
)
agi_memory = AGIMemorySystem(cfg)
except Exception as exc:
errors["agi_memory"] = str(exc)
return SharedSystems(adapter=adapter, consciousness=consciousness, agi_memory=agi_memory, errors=errors)
|