import sys,json
sys.path.insert(0,'/opt/struktur/knowledge-pipeline-aggregator-staging')
import knowledge_query as k
print(k.__file__)
class R:
    def __enter__(self): return self
    def __exit__(self,*a): pass
    def read(self): return json.dumps({'choices':[{'message':{'content':None,'reasoning':'x'}}]}).encode()
k.urllib.request.urlopen=lambda *a,**b:R()
k.env=lambda:'x'
print(k.synth('q','ctx',1))