updating README and adding Pydantic type instantiation to function connector

Author: TristenHarr

README.md

@@ -1,15 +1,18 @@
-Hasura Python SDK
+# Hasura Python SDK
 
-pip3 install hasura_ndc
+To install the library you can use:
 
-Work in progress
+`pip3 install hasura-ndc`
 
-python3 main.py serve --configuration config.json --port 8101 --service-token-secret secret
+Python developers can use this SDK to create Hasura Data Connectors using the Python programming language.
 
-python3 main.py configuration serve --port 9101
+You would be interested in this repository if you wanted to write your own Hasura data connector in Python that wrapped a database or custom data-source.
 
+Included in this SDK is an implementation of a Lambda connector, called a FunctionConnector. If you wanted to simply write Python code you'd likely be more interested in the Python Lambda connector which makes use of this, and you can find that repo here: https://github.com/hasura/ndc-python-lambda
 
-Upload to pypi:
+Developer notes:
+
+To upload a new version of the Hasura SDK to pypi:
 
 python3 setup.py sdist
 

hasura_ndc/function_connector.py

@@ -207,13 +207,19 @@ def get_type_info(typ, caller_name, object_types, arg_name=None):
 
     async def query(self, configuration: Configuration, state: State, request: QueryRequest) -> QueryResponse:
         args = {}
+        func = self.query_functions[request.collection]
+        signature = inspect.signature(func)
+
         for k, v in request.arguments.items():
             if v.type == "literal":
-                args[k] = v.value
+                arg_type = signature.parameters[k].annotation
+                if issubclass(arg_type, BaseModel):
+                    args[k] = arg_type(**v.value)
+                else:
+                    args[k] = v.value
             elif v.type == "variable":
                 raise Exception("Variable not supported yet")
 
-        func = self.query_functions[request.collection]
 
         if asyncio.iscoroutinefunction(func):
             result = await func(**args)
@@ -239,7 +245,15 @@ async def mutation(self,
         for operation in request.operations:
             operation_name = operation.name
             func = self.mutation_functions[operation_name]
-            args = operation.arguments if operation.arguments else {}
+            signature = inspect.signature(func)
+            args = {}
+            if operation.arguments:
+                for k, v in operation.arguments.items():
+                    arg_type = signature.parameters[k].annotation
+                    if issubclass(arg_type, BaseModel):
+                        args[k] = arg_type(**v)
+                    else:
+                        args[k] = v
             if asyncio.iscoroutinefunction(func):
                 response = await func(**args)
             else:

setup.py

@@ -6,7 +6,7 @@
 
 setup(
     name='hasura_ndc',
-    version='0.17',
+    version='0.18',
     packages=find_packages(),
     install_requires=[
         # This line reads the requirements from your `requirements.txt`