import asyncio,traceback
from graphiti_core.utils.maintenance import node_operations as n
from graphiti_core.nodes import EpisodeType
class E: source=EpisodeType.text; group_id='test'
async def main():
 old=n.extract_text_nodes
 async def fake(*a,**k): return [{'name':'A','labels':['Entity']}]
 n.extract_text_nodes=fake
 try: await n.extract_nodes(None,E(),[])
 except Exception:
  traceback.print_exc()
 finally: n.extract_text_nodes=old
asyncio.run(main())