Log when FunctionDispatcher is initialized. (#6230) (#6383)

Author: pragnagopa

src/WebJobs.Script/Workers/Http/HttpFunctionInvocationDispatcher.cs

@@ -65,14 +65,13 @@ public HttpFunctionInvocationDispatcher(IOptions<ScriptJobHostOptions> scriptHos
 
         internal Task InitializeHttpWorkerChannelAsync(int attemptCount, CancellationToken cancellationToken = default)
         {
-            // TODO: Add process managment for http invoker
             _httpWorkerChannel = _httpWorkerChannelFactory.Create(_scriptOptions.RootScriptPath, _metricsLogger, attemptCount);
             _httpWorkerChannel.StartWorkerProcessAsync(cancellationToken).ContinueWith(workerInitTask =>
                  {
                      if (workerInitTask.IsCompleted)
                      {
                          _logger.LogDebug("Adding http worker channel. workerId:{id}", _httpWorkerChannel.Id);
-                         State = FunctionInvocationDispatcherState.Initialized;
+                         SetFunctionDispatcherStateToInitializedAndLog();
                      }
                      else
                      {
@@ -82,6 +81,12 @@ internal Task InitializeHttpWorkerChannelAsync(int attemptCount, CancellationTok
             return Task.CompletedTask;
         }
 
+        private void SetFunctionDispatcherStateToInitializedAndLog()
+        {
+            State = FunctionInvocationDispatcherState.Initialized;
+            _logger.LogInformation("Worker process started and initialized.");
+        }
+
         public async Task InitializeAsync(IEnumerable<FunctionMetadata> functions, CancellationToken cancellationToken = default)
         {
             cancellationToken.ThrowIfCancellationRequested();

src/WebJobs.Script/Workers/Rpc/FunctionRegistration/RpcFunctionInvocationDispatcher.cs

@@ -122,7 +122,7 @@ internal Task InitializeJobhostLanguageWorkerChannelAsync(int attemptCount)
                 {
                     _logger.LogDebug("Adding jobhost language worker channel for runtime: {language}. workerId:{id}", _workerRuntime, rpcWorkerChannel.Id);
                     rpcWorkerChannel.SendFunctionLoadRequests(_managedDependencyOptions.Value);
-                    State = FunctionInvocationDispatcherState.Initialized;
+                    SetFunctionDispatcherStateToInitializedAndLog();
                 }
                 else
                 {
@@ -132,6 +132,13 @@ internal Task InitializeJobhostLanguageWorkerChannelAsync(int attemptCount)
             return Task.CompletedTask;
         }
 
+        private void SetFunctionDispatcherStateToInitializedAndLog()
+        {
+            State = FunctionInvocationDispatcherState.Initialized;
+            // Do not change this log message. Vs Code relies on this to figure out when to attach debuger to the worker process.
+            _logger.LogInformation("Worker process started and initialized.");
+        }
+
         internal async void InitializeWebhostLanguageWorkerChannel()
         {
             _logger.LogDebug("Creating new webhost language worker channel for runtime:{workerRuntime}.", _workerRuntime);
@@ -207,7 +214,7 @@ public async Task InitializeAsync(IEnumerable<FunctionMetadata> functions, Cance
                         }
                     }
                     StartWorkerProcesses(webhostLanguageWorkerChannels.Count(), InitializeWebhostLanguageWorkerChannel);
-                    State = FunctionInvocationDispatcherState.Initialized;
+                    SetFunctionDispatcherStateToInitializedAndLog();
                 }
                 else
                 {