feat: neural graft training, verified connectome caches, CPU compute budget & contract repairs
9e36559 | import os | |
| from synapse.config import SynapseConfig | |
| from synapse.runtime import LabRuntime | |
| def test_parallel_pretraining_uses_distinct_workers_and_real_transitions(tmp_path): | |
| from synapse.active_training import pretrain_runtime | |
| runtime=LabRuntime(SynapseConfig(nodes_per_source=16,neural_graft=True),tmp_path) | |
| result=pretrain_runtime(runtime,steps=4,updates=1,batch_size=4,workers=2) | |
| assert result['recorded_transitions']==4 | |
| assert result['workers_used']==2 | |
| assert len(set(result['worker_pids']))==2 | |
| assert os.getpid() not in result['worker_pids'] | |
| assert result['applied'] and result['policy_frozen'] | |
| assert runtime.total_steps==0 | |