diff --git a/src/funnel/main.py b/src/funnel/main.py index 15bb375..1b395d3 100644 --- a/src/funnel/main.py +++ b/src/funnel/main.py @@ -1,5 +1,4 @@ import asyncio -import logging import time from contextlib import asynccontextmanager from typing import AsyncGenerator, Optional @@ -32,6 +31,9 @@ async def get_serve_segments_stub() -> AsyncGenerator[ServeSegmentsStub, None]: async with grpc.aio.insecure_channel( f"{SERVE_SEGMENTS_HOST}:{SERVE_SEGMENTS_PORT}" ) as channel: + print( + f"🖥 Connected to ServeSegments server on {SERVE_SEGMENTS_HOST}:{SERVE_SEGMENTS_PORT}" + ) yield ServeSegmentsStub(channel) @@ -91,5 +93,4 @@ async def main(): if __name__ == "__main__": - logging.basicConfig() asyncio.run(main()) diff --git a/src/serve_currenttime/main.js b/src/serve_currenttime/main.js index 432e84f..d477d84 100644 --- a/src/serve_currenttime/main.js +++ b/src/serve_currenttime/main.js @@ -21,7 +21,6 @@ const PROTO_PACKAGE_OPTIONS = { function getCurrentTime(call, callback) { const timezone = call.request.timezone; - console.log("Received timezone:", timezone); const now = dayjs().tz(timezone); callback(null, { @@ -43,7 +42,9 @@ function main() { }); server.bindAsync(`${SERVE_CURRENTTIME_HOST}:${SERVE_CURRENTTIME_PORT}`, ServerCredentials.createInsecure(), () => { - console.log(`Starting server on ${SERVE_CURRENTTIME_HOST}:${SERVE_CURRENTTIME_PORT}`); + console.log( + `🖧 Starting ServeCurrentTime NodeJS server on ${SERVE_CURRENTTIME_HOST}:${SERVE_CURRENTTIME_PORT}` + ); server.start(); }); } diff --git a/src/serve_segments/main.go b/src/serve_segments/main.go index 65e7421..b20f6a0 100644 --- a/src/serve_segments/main.go +++ b/src/serve_segments/main.go @@ -98,7 +98,7 @@ func serve() { // create ServeSegments server server := grpc.NewServer() pb_serve_segments.RegisterServeSegmentsServer(server, &grpc_server{}) - log.Printf("server listening at %v", lis.Addr()) + log.Printf("🖧 Starting ServeSegments Go server on %v", lis.Addr()) // create connection to ServeCurrentTime server getCurrentTimeConn, err := grpc.Dial(