zzstoatzz.io
prefect server in zig
fix benchmark harness to capture server errors without blocking
- use DEVNULL during normal benchmark runs to avoid pipe buffer deadlock
- on startup failure, restart with PIPE to capture error output
- display actual error message instead of generic "failed to start server"
🤖 Generated with [Claude Code](https://claude.com/claude-code)
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
+1
-1
loq.toml
+1
-1
loq.toml
+21
-1
scripts/benchmark
+21
-1
scripts/benchmark
···
155
self.broker_backend = broker_backend
156
self.process: subprocess.Popen | None = None
157
self.project_root = Path(__file__).parent.parent
158
159
def start(self) -> bool:
160
"""Start the server."""
···
182
if self.db_backend == "postgres":
183
env.setdefault("PREFECT_DATABASE_URL", "postgresql://prefect:prefect@localhost:5432/prefect")
184
185
self.process = subprocess.Popen(
186
[str(binary)],
187
cwd=self.project_root,
···
191
)
192
193
if not wait_for_health():
194
self.stop()
195
return False
196
return True
···
525
manager = ServerManager(server_type, db_backend, broker_backend)
526
if not manager.start():
527
console.print("[red]failed[/red]")
528
return BenchmarkResult(
529
server=server_type,
530
success=False,
···
532
endpoints=[],
533
db_backend=db_backend,
534
broker_backend=broker_backend,
535
-
error="failed to start server",
536
)
537
538
console.print("running benchmark...", end=" ")
···
155
self.broker_backend = broker_backend
156
self.process: subprocess.Popen | None = None
157
self.project_root = Path(__file__).parent.parent
158
+
self.startup_error: str | None = None
159
160
def start(self) -> bool:
161
"""Start the server."""
···
183
if self.db_backend == "postgres":
184
env.setdefault("PREFECT_DATABASE_URL", "postgresql://prefect:prefect@localhost:5432/prefect")
185
186
+
# first attempt: DEVNULL to avoid buffer issues during benchmark
187
self.process = subprocess.Popen(
188
[str(binary)],
189
cwd=self.project_root,
···
193
)
194
195
if not wait_for_health():
196
+
self.stop()
197
+
# restart with output capture to get error message
198
+
self.process = subprocess.Popen(
199
+
[str(binary)],
200
+
cwd=self.project_root,
201
+
env=env,
202
+
stdout=subprocess.PIPE,
203
+
stderr=subprocess.STDOUT,
204
+
text=True,
205
+
)
206
+
time.sleep(2) # give server time to fail
207
+
if self.process.poll() is not None:
208
+
output, _ = self.process.communicate()
209
+
self.startup_error = output.strip()[-500:] if output else "server exited"
210
+
else:
211
+
self.startup_error = "health check timeout"
212
self.stop()
213
return False
214
return True
···
543
manager = ServerManager(server_type, db_backend, broker_backend)
544
if not manager.start():
545
console.print("[red]failed[/red]")
546
+
if manager.startup_error:
547
+
console.print(f"[dim]{manager.startup_error}[/dim]")
548
return BenchmarkResult(
549
server=server_type,
550
success=False,
···
552
endpoints=[],
553
db_backend=db_backend,
554
broker_backend=broker_backend,
555
+
error=manager.startup_error or "failed to start server",
556
)
557
558
console.print("running benchmark...", end=" ")