Intis/clocker-demo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Prettify output

Browse Source
This commit is contained in:
Eden Kirin
2023-03-23 00:21:20 +01:00
parent 544b7d6c85
commit 8d1e31ac5f
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/funnel/main.py
View File

@ -28,12 +28,9 @@ TIMEZONE = "Europe/Zagreb"
@asynccontextmanager @asynccontextmanager
async def get_serve_segments_stub() -> AsyncGenerator[ServeSegmentsStub, None]: async def get_serve_segments_stub() -> AsyncGenerator[ServeSegmentsStub, None]:
"""Connect to segments server and create stub""" """Connect to segments server and create stub"""
async with grpc.aio.insecure_channel( serve_segments_addr = f"{SERVE_SEGMENTS_HOST}:{SERVE_SEGMENTS_PORT}"
f"{SERVE_SEGMENTS_HOST}:{SERVE_SEGMENTS_PORT}" async with grpc.aio.insecure_channel(serve_segments_addr) as channel:
) as channel: print(f"🖥 Connected to ServeSegments server on {serve_segments_addr}")
print(
f"🖥 Connected to ServeSegments server on {SERVE_SEGMENTS_HOST}:{SERVE_SEGMENTS_PORT}"
)
yield ServeSegmentsStub(channel) yield ServeSegmentsStub(channel)