diff --git a/src/Dapr.Workflow/Logging.cs b/src/Dapr.Workflow/Logging.cs index 3d65cdc82..fa404b59c 100644 --- a/src/Dapr.Workflow/Logging.cs +++ b/src/Dapr.Workflow/Logging.cs @@ -88,6 +88,9 @@ internal static partial class Logging [LoggerMessage(LogLevel.Information, "Starting gRPC bidirectional stream with Dapr sidecar")] public static partial void LogGrpcProtocolHandlerStartStream(this ILogger logger); + [LoggerMessage(LogLevel.Information, "Established gRPC bidirectional stream with Dapr sidecar")] + public static partial void LogGrpcProtocolHandlerStreamEstablished(this ILogger logger); + [LoggerMessage(LogLevel.Information, "gRPC stream canceled")] public static partial void LogGrpcProtocolHandlerStreamCanceled(this ILogger logger); diff --git a/src/Dapr.Workflow/Worker/Grpc/GrpcProtocolHandler.cs b/src/Dapr.Workflow/Worker/Grpc/GrpcProtocolHandler.cs index e5f0410f0..c7d4a08a4 100644 --- a/src/Dapr.Workflow/Worker/Grpc/GrpcProtocolHandler.cs +++ b/src/Dapr.Workflow/Worker/Grpc/GrpcProtocolHandler.cs @@ -68,10 +68,12 @@ public async Task StartAsync( // Establish the server streaming call _streamingCall = _grpcClient.GetWorkItems(request, cancellationToken: token); + _logger.LogGrpcProtocolHandlerStreamEstablished(); + // Process work items from the stream await ReceiveLoopAsync(_streamingCall.ResponseStream, workflowHandler, activityHandler, token); - // Stream ended gracefully => tradfe as an interrupted and reconnect unless shutting down + // Stream ended gracefully => treat as an interrupted and reconnect unless shutting down if (!token.IsCancellationRequested) { await DelayOrStopAsync(ReconnectDelay, token);