refactor: simplify FlushModuleOutput - modules now flush immediately

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: thomhurst

src/ModularPipelines/Console/ConsoleCoordinator.cs

@@ -262,38 +262,22 @@ public IModuleOutputBuffer GetModuleBuffer(Type moduleType)
     /// <inheritdoc />
     public void FlushModuleOutput()
     {
+        // Output is now flushed immediately when modules complete.
+        // This method remains for API compatibility but only flushes
+        // unattributed output (pipeline-level logs).
         if (_originalConsoleOut == null)
         {
-            throw new InvalidOperationException("ConsoleCoordinator is not installed.");
+            return; // Not installed, nothing to flush
         }
 
         var formatter = _formatterProvider.GetFormatter();
 
-        // Flush unattributed output first (if any)
+        // Flush unattributed output (if any)
         if (_unattributedBuffer.HasOutput)
         {
             var unattributedLogger = _outputLogger ?? _loggerFactory.CreateLogger("ModularPipelines.Output");
             _unattributedBuffer.FlushTo(_originalConsoleOut, formatter, unattributedLogger);
         }
-
-        // Flush module buffers in completion order
-        var orderedBuffers = _moduleBuffers.Values
-            .Where(b => b.HasOutput)
-            .OrderBy(b => b.CompletedAtUtc ?? DateTime.MaxValue)
-            .ToList();
-
-        foreach (var buffer in orderedBuffers)
-        {
-            // Resolve the registered ILogger<T> from DI to use any custom loggers injected by tests
-            var loggerType = typeof(ILogger<>).MakeGenericType(buffer.ModuleType);
-            var moduleLogger = (ILogger)_serviceProvider.GetService(loggerType)
-                               ?? _loggerFactory.CreateLogger(buffer.ModuleType);
-            buffer.FlushTo(_originalConsoleOut, formatter, moduleLogger);
-        }
-
-        // Clear buffers after flush to release memory
-        // This prevents accumulation in long-running pipelines
-        _moduleBuffers.Clear();
     }
 
     /// <inheritdoc />

src/ModularPipelines/Console/IConsoleCoordinator.cs

@@ -72,10 +72,9 @@ internal interface IConsoleCoordinator : IAsyncDisposable
     IModuleOutputBuffer GetUnattributedBuffer();
 
     /// <summary>
-    /// Flushes all module output in completion order.
-    /// Should be called after progress phase ends.
+    /// Flushes any remaining unattributed output.
+    /// Module output is flushed immediately when modules complete.
     /// </summary>
-    /// <exception cref="InvalidOperationException">Thrown if not installed.</exception>
     void FlushModuleOutput();
 
     /// <summary>