gabriel-client

import asyncio from gabriel_client import ClientRunner from gabriel_client.websocket_engine import websocket_engine async def main(): server_address = 'localhost' port = 9099 token = os.environ.get('GABRIEL_TOKEN', 'test_token') engine_name = 'my_engine' source = lambda: b'hello' # dummy source, replace with actual engine = websocket_engine(server_address, port, token, source) runner = ClientRunner(engine, engine_name) await runner.run() if __name__ == '__main__': asyncio.run(main())