Added logging line after the gRPC stream has been established without error with the sidecar from the workflow SDK (#1688)

Signed-off-by: Whit Waldo <[email protected]>

Author: WhitWaldo

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);
 

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);