mirror of
https://github.com/CopilotKit/CopilotKit.git
synced 2026-09-14 16:26:20 +08:00
a3d93266e9
Real demo-time bugs in the langgraph-python integration:
- `interrupt-headless` was rendering hardcoded stale slot dates from a
`DEFAULT_SLOTS` constant instead of reading `payload.slots` that the
backend `interrupt(...)` already supplies. Sibling `gen-ui-interrupt`
does this correctly. Headless variant now matches.
- `_shared/interrupt-fallback-slots.ts` (new) — the JS fallback for
when the backend returns no `slots` array. Generates relative to
Date.now() so the picker never shows past dates. Used by both
`interrupt-headless` and `gen-ui-interrupt`. Deletes the old stale-
literal `gen-ui-interrupt/fallback-slots.ts` (dates from April that
had already decayed).
- `interrupt_agent.py` — replaced hardcoded `timezone(timedelta(-7))`
PDT with `zoneinfo.ZoneInfo("America/Los_Angeles")` so the demo
doesn't lie about offsets in winter. Also fixed a Sunday edge case
where `next_monday` collapsed to the same date as `tomorrow` (both
Python and the JS fallback) — added a `<= 1` skip-a-week guard.
- `package.json#dev` ran `uvicorn agent_server:app --port 8000` but
`src/agent_server.py` was a 3-line stub with no `app` symbol AND the
API route pointed at port 8123. Replaced with the canonical
`langgraph_cli dev --port 8123` invocation; deleted the dead stub.
- `entrypoint.sh:47` smoke-checked `src/agents/tools.py` (a file that
never existed) so every Railway boot logged a phantom ERROR. Dropped.
- `reasoning_agent.py` and `tool_rendering_reasoning_chain_agent.py`
intentionally omit `CopilotKitMiddleware` (they exercise only
reasoning-token streaming, no frontend tools / app context). Added a
one-line comment so a future maintainer doesn't cargo-cult it back in.
- `subagents._invoke_sub_agent` text-block walker had a regression
where a `{"type":"text","text":null}` payload (a known provider
quirk) would crash `"".join(parts)` with `TypeError: sequence item
N: expected str instance, NoneType found`. Restored the
`isinstance(block.get("text"), str)` guard.
Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
166 lines
6.7 KiB
Bash
166 lines
6.7 KiB
Bash
#!/bin/bash
|
|
set -e
|
|
|
|
cleanup() {
|
|
kill $LANGGRAPH_PID $NEXTJS_PID $WATCHDOG_PID 2>/dev/null || true
|
|
}
|
|
trap cleanup EXIT
|
|
|
|
# Disable Python stdout buffering so langgraph_cli's dev server and any
|
|
# tracebacks it emits reach the Railway log stream immediately rather than
|
|
# sitting in Python's userspace buffer until the process exits. Paired with
|
|
# `python -u` on the langgraph_cli invocation below.
|
|
export PYTHONUNBUFFERED=1
|
|
|
|
echo "========================================="
|
|
echo "[entrypoint] Starting showcase: langgraph-python"
|
|
echo "[entrypoint] Time: $(date -u)"
|
|
echo "[entrypoint] PWD: $(pwd)"
|
|
echo "[entrypoint] PORT=${PORT:-not set}"
|
|
echo "[entrypoint] NODE_ENV=${NODE_ENV:-not set}"
|
|
echo "========================================="
|
|
|
|
# Check critical env vars
|
|
echo "[entrypoint] Checking environment variables..."
|
|
if [ -z "$OPENAI_API_KEY" ]; then
|
|
echo "[entrypoint] WARNING: OPENAI_API_KEY is not set! Agent will fail."
|
|
else
|
|
echo "[entrypoint] OPENAI_API_KEY: set (${#OPENAI_API_KEY} chars)"
|
|
fi
|
|
|
|
if [ -z "$ANTHROPIC_API_KEY" ]; then
|
|
echo "[entrypoint] INFO: ANTHROPIC_API_KEY is not set"
|
|
else
|
|
echo "[entrypoint] ANTHROPIC_API_KEY: set (${#ANTHROPIC_API_KEY} chars)"
|
|
fi
|
|
|
|
if [ -z "$LANGSMITH_API_KEY" ]; then
|
|
echo "[entrypoint] INFO: LANGSMITH_API_KEY is not set (tracing disabled)"
|
|
else
|
|
echo "[entrypoint] LANGSMITH_API_KEY: set (${#LANGSMITH_API_KEY} chars)"
|
|
fi
|
|
|
|
# Verify files exist
|
|
echo "[entrypoint] Checking files..."
|
|
ls -la langgraph.json 2>/dev/null && echo "[entrypoint] langgraph.json: OK" || echo "[entrypoint] ERROR: langgraph.json missing!"
|
|
ls -la src/agents/main.py 2>/dev/null && echo "[entrypoint] src/agents/main.py: OK" || echo "[entrypoint] ERROR: src/agents/main.py missing!"
|
|
ls -la .next/server 2>/dev/null > /dev/null && echo "[entrypoint] .next/server: OK" || echo "[entrypoint] ERROR: .next build missing!"
|
|
|
|
echo "[entrypoint] langgraph.json contents:"
|
|
cat langgraph.json
|
|
|
|
echo "========================================="
|
|
echo "[entrypoint] Starting LangGraph agent server on port 8123..."
|
|
echo "========================================="
|
|
|
|
# `python -u` forces unbuffered stdout/stderr at the interpreter level
|
|
# (belt-and-suspenders with PYTHONUNBUFFERED=1 above) so langgraph_cli boot
|
|
# failures surface in the Railway log stream immediately rather than sitting
|
|
# in a pipe buffer until the process exits. `awk ... fflush()` replaces the
|
|
# previous `sed` formulation — process substitution leaves $! pointing at
|
|
# the real python process (pipe form made $! point at sed).
|
|
python -u -m langgraph_cli dev \
|
|
--config langgraph.json \
|
|
--host 0.0.0.0 \
|
|
--port 8123 \
|
|
--no-browser &> >(awk '{print "[langgraph] " $0; fflush()}') &
|
|
LANGGRAPH_PID=$!
|
|
|
|
# Give langgraph a moment to start
|
|
sleep 3
|
|
|
|
# Check if langgraph is still running
|
|
if kill -0 $LANGGRAPH_PID 2>/dev/null; then
|
|
echo "[entrypoint] LangGraph agent server started (PID: $LANGGRAPH_PID)"
|
|
else
|
|
echo "[entrypoint] ERROR: LangGraph agent server failed to start!"
|
|
echo "[entrypoint] Continuing with Next.js only (demos will show agent errors)"
|
|
fi
|
|
|
|
echo "========================================="
|
|
echo "[entrypoint] Starting Next.js frontend on port ${PORT:-10000}..."
|
|
echo "========================================="
|
|
|
|
PORT=${PORT:-10000}
|
|
# Scope NODE_ENV=production to the Next.js invocation ONLY, not the whole
|
|
# container environment. `ENV NODE_ENV=production` at the image level would
|
|
# leak into the Python langgraph process and any shell subprocesses; scope
|
|
# it here so non-Next children see the host's environment.
|
|
env NODE_ENV=production npx next start --port $PORT &> >(awk '{print "[nextjs] " $0; fflush()}') &
|
|
NEXTJS_PID=$!
|
|
|
|
echo "[entrypoint] Next.js started (PID: $NEXTJS_PID)"
|
|
|
|
# Watchdog: Railway deploys of showcase packages have been observed to hit a
|
|
# silent agent hang — the langgraph process stays alive (so `wait -n` never
|
|
# fires and the container never restarts) but stops responding on :8123.
|
|
# Poll the langgraph_cli /ok endpoint every 30s; after 3 consecutive failures
|
|
# (~90s of unreachable agent), kill the agent process so `wait -n` returns
|
|
# and Railway restarts the container. Generalized from
|
|
# showcase/integrations/crewai-crews/entrypoint.sh (PRs #4114 + #4115).
|
|
#
|
|
# Startup grace: langgraph_cli dev does a heavy cold-start (graph compile
|
|
# + uvicorn boot). On fresh Railway containers this can exceed the 90s
|
|
# (3-strike) budget introduced in PR #4116, matching the restart loop
|
|
# observed on langgraph-typescript (deployment
|
|
# 58bbebe8-7a94-4f99-b6e4-ffcbb4eb78b9, 04-20 17:05 UTC). Wait up to 180s
|
|
# for the first healthy /ok probe before arming the strike counter; if
|
|
# /ok comes up sooner, fall through immediately. If 180s elapses without
|
|
# success, arm the counter anyway — the steady-state watchdog will then
|
|
# handle a true hang.
|
|
(
|
|
GRACE=180
|
|
echo "[watchdog] Startup grace: waiting up to ${GRACE}s for first successful health probe before arming strike counter"
|
|
ELAPSED=0
|
|
while [ $ELAPSED -lt $GRACE ]; do
|
|
if ! kill -0 $LANGGRAPH_PID 2>/dev/null; then
|
|
# Agent died during startup — wait -n in the main shell will handle it.
|
|
exit 0
|
|
fi
|
|
if curl -fsS --max-time 5 http://127.0.0.1:8123/ok > /dev/null 2>&1; then
|
|
echo "[watchdog] Agent healthy after ${ELAPSED}s — arming strike counter"
|
|
break
|
|
fi
|
|
sleep 5
|
|
ELAPSED=$((ELAPSED + 5))
|
|
done
|
|
if [ $ELAPSED -ge $GRACE ]; then
|
|
echo "[watchdog] Grace window elapsed without successful probe — arming strike counter anyway"
|
|
fi
|
|
FAILS=0
|
|
while sleep 30; do
|
|
if ! kill -0 $LANGGRAPH_PID 2>/dev/null; then
|
|
break
|
|
fi
|
|
if curl -fsS --max-time 5 http://127.0.0.1:8123/ok > /dev/null 2>&1; then
|
|
FAILS=0
|
|
else
|
|
FAILS=$((FAILS + 1))
|
|
echo "[watchdog] Agent health probe failed (count=$FAILS)"
|
|
if [ $FAILS -ge 3 ]; then
|
|
echo "[watchdog] Agent unresponsive for ~90s — killing PID $LANGGRAPH_PID to trigger container restart"
|
|
kill -9 $LANGGRAPH_PID 2>/dev/null || true
|
|
break
|
|
fi
|
|
fi
|
|
done
|
|
) &
|
|
WATCHDOG_PID=$!
|
|
echo "[entrypoint] Watchdog started (PID: $WATCHDOG_PID, probing http://127.0.0.1:8123/ok, startup grace 180s)"
|
|
echo "[entrypoint] All processes running. Waiting..."
|
|
|
|
# Only wait on agent + next.js — NOT the watchdog. The watchdog's job is to
|
|
# kill the agent when it hangs; if the watchdog exits first (e.g. because it
|
|
# killed the agent), wait -n would otherwise return with the watchdog's exit
|
|
# code and short-circuit before the agent's true exit status is observable.
|
|
wait -n $LANGGRAPH_PID $NEXTJS_PID
|
|
EXIT_CODE=$?
|
|
if ! kill -0 $LANGGRAPH_PID 2>/dev/null; then
|
|
echo "[entrypoint] LangGraph (PID: $LANGGRAPH_PID) exited with code $EXIT_CODE"
|
|
elif ! kill -0 $NEXTJS_PID 2>/dev/null; then
|
|
echo "[entrypoint] Next.js (PID: $NEXTJS_PID) exited with code $EXIT_CODE"
|
|
else
|
|
echo "[entrypoint] A process exited with code $EXIT_CODE"
|
|
fi
|
|
exit $EXIT_CODE
|