Add .serve() for python client

javascript/package.json

@@ -1,6 +1,6 @@
 {
  "name": "hypha-rpc",
- "version": "0.20.14",
+ "version": "0.20.15",
  "description": "Hypha RPC client for connecting to Hypha server for data management and AI model serving.",
  "main": "index.js",
  "types": "index.d.ts",

python/hypha_rpc/VERSION

@@ -1,3 +1,3 @@
 {
- "version": "0.20.14"
+ "version": "0.20.15"
 }

python/hypha_rpc/utils/schema.py

@@ -173,6 +173,7 @@ async def wrapper(*args, **kwargs):
  new_args, new_kwargs = fill_missing_args_and_kwargs(
  original_func_sig, args, kwargs
  )
+ # TODO: Validate the input types
  return await original_func(*new_args, **new_kwargs)
 
  else:
@@ -182,6 +183,7 @@ def wrapper(*args, **kwargs):
  new_args, new_kwargs = fill_missing_args_and_kwargs(
  original_func_sig, args, kwargs
  )
+ # TODO: Validate the input types
  return original_func(*new_args, **new_kwargs)
 
  wrapper.__schema__ = {
@@ -372,6 +374,7 @@ def process_arguments(args, kwargs):
  arg = annotation.model_validate(arg)
  except ValidationError:
  pass
+ # TODO: Validate the input, for primitive types and Pydantic models
  final_args.append(arg)
 
  final_kwargs = {}

python/hypha_rpc/websocket_client.py

@@ -675,6 +675,14 @@ async def handle_disconnect(message):
  "type": "object",
  },
  )
+
+ def serve():
+ loop = asyncio.get_event_loop()
+ loop.run_forever()
+
+ wm.serve = schema_function(
+ serve, name="serve", description="Start the event loop", parameters={}
+ )
  return wm
 
 

python/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "hypha_rpc"
-version = "0.20.14"
+version = "0.20.15"
 description = "Hypha RPC client for connecting to Hypha server for data management and AI model serving"
 readme = "README.md"
 requires-python = ">=3.6"