fix: flush streamed sqs process output

carlalexander · carlalexander · commit 56fa193d8faa · 2026-05-16T17:22:31.000-04:00
diff --git a/src/Lambda/Handler/Sqs/AbstractIlluminateQueueSqsHandler.php b/src/Lambda/Handler/Sqs/AbstractIlluminateQueueSqsHandler.php
@@ -93,7 +93,10 @@ final protected function processRecord(InvocationContext $context, SqsRecord $re
      */
     protected function writeProcessOutput(string $type, string $output): void
     {
-        fwrite(Process::ERR === $type ? STDERR : STDOUT, $output);
+        $stream = Process::ERR === $type ? STDERR : STDOUT;
+
+        fwrite($stream, $output);
+        fflush($stream);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -93,7 +93,10 @@ final protected function processRecord(InvocationContext $context, SqsRecord $re`
`93`	`93`	`*/`
`94`	`94`	`protected function writeProcessOutput(string $type, string $output): void`
`95`	`95`	`{`
`96`		`- fwrite(Process::ERR === $type ? STDERR : STDOUT, $output);`
	`96`	`+ $stream = Process::ERR === $type ? STDERR : STDOUT;`
	`97`	`+`
	`98`	`+ fwrite($stream, $output);`
	`99`	`+ fflush($stream);`
`97`	`100`	`}`
`98`	`101`
`99`	`102`	`/**`