Skip to content

Support grpc options #188

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
iciclespider merged 4 commits into from
Nov 24, 2025
+7 −1
Merged

Support grpc options #188

Changes from 2 commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
2abab1d
support grpc server options
P0t4T0o Nov 20, 2025
01f7a06
update
P0t4T0o Nov 20, 2025
6094cad
fix lint issues
P0t4T0o Nov 24, 2025
cf9611c
add example to docstring
P0t4T0o Nov 24, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion crossplane/function/runtime.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@
import asyncio
import os
import signal
from typing import Any, Sequence, Tuple

import grpc
from grpc_reflection.v1alpha import reflection
Expand Down Expand Up @@ -73,6 +74,7 @@ def serve(
*,
creds: grpc.ServerCredentials,
insecure: bool,
options: Sequence[Tuple[str, Any]] = None,
) -> None:
"""Start a gRPC server and serve requests asychronously.

Expand All @@ -91,7 +93,7 @@ def serve(
# Define the loop before the server so everything uses the same loop.
loop = asyncio.get_event_loop()

server = grpc.aio.server()
server = grpc.aio.server(options=options)

loop.add_signal_handler(
signal.SIGTERM,
Expand Down
Loading