update to add variable support and add parallel execution

Author: Tristen Harr

CHANGELOG.md

@@ -4,6 +4,10 @@ This changelog documents the changes between release versions.
 ## [Unreleased]
 Changes to be included in the next upcoming release
 
+## [0.0.36] - 2024-08-07
+* Add support for query variables
+* Add support for parallel query execution
+
 ## [0.0.35] - 2024-08-05
 * Update SDK to listen on IPV4 & IPV6
 

connector-definition/template/functions.py

@@ -12,6 +12,7 @@
 from opentelemetry.trace import get_tracer # If you aren't planning on adding additional tracing spans, you don't need this either!
 from hasura_ndc.function_connector import FunctionConnector
 from pydantic import BaseModel # You only need this import if you plan to have complex inputs/outputs, which function similar to how frameworks like FastAPI do
+import asyncio # You might not need this import if you aren't doing asynchronous work
 
 connector = FunctionConnector()
 
@@ -92,6 +93,11 @@ async def do_some_async_work(_span):
         {"tracing-attr": "Additional attributes can be added to Otel spans by making use of with_active_span like this"}
     )
 
+# This is an example of how to setup queries to be run in parallel
+@connector.register_query(parallel_degree=5) # When joining to this function, it will be executed in parallel in batches of 5
+async def parallel_query(name: str) -> str:
+    await asyncio.sleep(1)
+    return f"Hello {name}"
 
 if __name__ == "__main__":
     start(connector)

connector-definition/template/requirements.txt

@@ -9,7 +9,7 @@ fastapi==0.110.2
 googleapis-common-protos==1.63.0
 grpcio==1.62.2
 h11==0.14.0
-hasura-ndc==0.21
+hasura-ndc==0.22
 idna==3.7
 importlib-metadata==7.0.0
 opentelemetry-api==1.24.0