Buoys, surf forecasts and the aircraft worth a row - #40
Merged
Conversation
Three sources, all keyless, all verified live before they were written.
BUOYS AND SURF, INTO WATER
NDBC publishes the newest observation from every buoy it is listening to in one
hundred-kilobyte file: 853 reports, 184 of them carrying a wave height. Wave
height, dominant period and mean direction are what a surf report is actually
made of, and the period is the number people leave out -- two metres at 18
seconds and two metres at 5 seconds are completely different days in the water.
So a wave row is published as "8.9 ft at 8 s, mixed swell out of the W" as well
as stored as numbers, in feet as well as metres, because every US surf forecast
is in feet and converting at read time is how a nine-foot day becomes a
three-foot day.
Beside it, the National Weather Service Surf Zone Forecast from every coastal
office, in full. A buoy off Oahu reading 2.4 m at 16 seconds is a fact;
"advisory level surf along south facing shores through today" is what it means
to anyone standing on the beach, and no arithmetic over the buoy produces it.
The high surf advisory and the rip current risk are lifted from the
forecaster's own wording into tags so a coast under an advisory can be found
without reading 851 products, and the full text is stored as the authority.
AIRCRAFT, INTO AVIATION
There is a version of this that stores every aeroplane in the sky every few
minutes. It would be tens of thousands of rows a day, each a position that was
true for four seconds, and nobody would read one. A position is not news; an
aircraft squawking 7700 is. So this reads the event surfaces: the three
emergency transponder codes and the military list. At the time of writing the
emergency codes returned zero aircraft between them and the military query
returned 422, which is the shape you want -- the rare thing is rare, so its
appearance means something.
An emergency is an episode, not a ping, and it is held the same way
`faa-nas-status` holds a ground stop: open episodes live in the cursor keyed on
the ICAO hex, the row is keyed on when the aircraft was first seen, and when it
leaves the list it is written once more with a duration. "N123AB squawked 7700
for 22 minutes" is the row. The forty positions in between are not.
FOUR THINGS THE LIVE DATA DECIDED
- NDBC writes a missing reading as `MM`, in every column, in a fixed-width
table. `Number('MM') || 0` turns "this buoy has no anemometer" into a flat
calm and "no wave sensor" into a dead-flat sea, and 669 of 853 stations
report no wave height at all. One guard, and null means the buoy did not say.
- The station register really does publish `name=""` -- 15009 in the Atlantic
array is one of several. An empty string is not a name, and left as one it
beats the fallback and titles the row with nothing at all. That was visible
in the first smoke run as rows titled ": marine observation".
- Some stations report a dominant period of 0 or 1 second. That is a sensor
saying nothing, and classifying it as "windswell" states something about the
water nobody measured. Under two seconds, the period is left out.
- adsb.lol rate limits `/v2/mil` far harder than the squawk lists: it answered
429 while `/sqk/7700` beside it answered 200. A limit is not a failure, so it
returns no items and asks to be called back, which also keeps the cursor
intact -- a run that threw there would leave every open episode untouched and
then report them all as ended on the run after.
ALSO CORRECTED
The comment added in #38 said the NTSB reader slices its output because
`upsertItems` sends every row in one statement. That is wrong: `runSource`
already chunks writes into batches of 200. The slicing is still right, for the
reasons now stated -- 140 MB of narrative text held in memory, and the
four-minute ingest deadline -- but the stated reason was not the real one.
Verified live: 853 buoy observations with 184 reporting waves and one station
over 2.5 m; 40 Pacific and 23 Hawaii surf forecasts with the Honolulu high surf
advisory correctly tagged; all three emergency squawk lists answering with zero
aircraft, which is the correct answer. 596 tests pass, biome clean.
Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01CjTtJPEpyJbvPeQcVfYPPs
ralyodio
added a commit
that referenced
this pull request
Sep 9, 2026
Since 0.4.0: #40 added three keyless sources. NDBC's every-buoy file into water, with wave height, period and direction read out the way a surf report says them; the National Weather Service surf zone forecast from every coastal office beside it; and the ADS-B emergency squawk and military watch lists into aviation, held as episodes rather than as positions. Twenty-seven collections, seventy-nine adapters. Claude-Session: https://claude.ai/code/session_01CjTtJPEpyJbvPeQcVfYPPs Co-authored-by: Claude Opus 5 (1M context) <noreply@anthropic.com>
ralyodio
added a commit
that referenced
this pull request
Sep 9, 2026
* 0.5.0: buoys, surf forecasts and aircraft on watch Since 0.4.0: #40 added three keyless sources. NDBC's every-buoy file into water, with wave height, period and direction read out the way a surf report says them; the National Weather Service surf zone forecast from every coastal office beside it; and the ADS-B emergency squawk and military watch lists into aviation, held as episodes rather than as positions. Twenty-seven collections, seventy-nine adapters. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01CjTtJPEpyJbvPeQcVfYPPs * A rollout should cost a source two minutes, not a day Three deploys this afternoon each stranded a batch of freshly seeded sources, and the reason is worse than the error text suggests. When a deploy adds adapters, the new container seeds their sources and enqueues the first runs, and the container still draining takes some of those jobs. It does not have the new adapters, so `runSource` writes `unknown adapter`. That part is harmless and self-correcting. What is not harmless is that `startRun` pushes `next_run_at` a full cadence forward BEFORE the adapter is looked up. So the source does not fail and retry. It forfeits its whole slot. Measured on the live database just now: every 5m recovered within minutes (aircraft-emergency, run 2, 1 item) every 60m next attempt 19:50 (~1 hour of nothing) every 180m next attempt 21:50 (3 hours) every 720m next attempt 06:50 TOMORROW (11 hours) every 1440m next attempt 18:50 TOMORROW (23 hours) Twenty-four of thirty-six new sources were sitting in that state, most of a day of silence bought by a rollout that lasted seconds. "It heals on the next run" was true and almost useless. Two changes. The unknown-adapter path now asks to be called back in two minutes instead of letting the forfeited slot stand. Two minutes covers a rollout overlap and costs nothing if the adapter really is gone, because the run after that parks it again. And `ensureDefaults` now brings forward anything already parked on that error for an adapter this build actually has. Boot is exactly the moment the adapter appears, so it is the right place to ask. The query is deliberately narrow: only `unknown adapter`, only adapters now registered, only enabled sources, only ones not already due. A source that failed for any other reason keeps its schedule, and one naming an adapter that genuinely no longer exists stays parked rather than spinning the scheduler every tick. Both are tested against a real Postgres in process rather than mocked, because the entire behaviour lives in an `update ... where` and there is nothing else to check. Eight tests: the repair works, it is idempotent, it ignores other errors, it ignores deleted adapters, it ignores disabled sources, an empty adapter list is not a wildcard, and the full-cadence forfeit is pinned so nobody removes the two-minute retry without a test going red. 604 tests pass, biome clean. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01CjTtJPEpyJbvPeQcVfYPPs --------- Co-authored-by: Claude Opus 5 (1M context) <noreply@anthropic.com>
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Three sources, all keyless, all verified live before they were written.
BUOYS AND SURF, INTO WATER
NDBC publishes the newest observation from every buoy it is listening to in one
hundred-kilobyte file: 853 reports, 184 of them carrying a wave height. Wave
height, dominant period and mean direction are what a surf report is actually
made of, and the period is the number people leave out -- two metres at 18
seconds and two metres at 5 seconds are completely different days in the water.
So a wave row is published as "8.9 ft at 8 s, mixed swell out of the W" as well
as stored as numbers, in feet as well as metres, because every US surf forecast
is in feet and converting at read time is how a nine-foot day becomes a
three-foot day.
Beside it, the National Weather Service Surf Zone Forecast from every coastal
office, in full. A buoy off Oahu reading 2.4 m at 16 seconds is a fact;
"advisory level surf along south facing shores through today" is what it means
to anyone standing on the beach, and no arithmetic over the buoy produces it.
The high surf advisory and the rip current risk are lifted from the
forecaster's own wording into tags so a coast under an advisory can be found
without reading 851 products, and the full text is stored as the authority.
AIRCRAFT, INTO AVIATION
There is a version of this that stores every aeroplane in the sky every few
minutes. It would be tens of thousands of rows a day, each a position that was
true for four seconds, and nobody would read one. A position is not news; an
aircraft squawking 7700 is. So this reads the event surfaces: the three
emergency transponder codes and the military list. At the time of writing the
emergency codes returned zero aircraft between them and the military query
returned 422, which is the shape you want -- the rare thing is rare, so its
appearance means something.
An emergency is an episode, not a ping, and it is held the same way
faa-nas-statusholds a ground stop: open episodes live in the cursor keyed onthe ICAO hex, the row is keyed on when the aircraft was first seen, and when it
leaves the list it is written once more with a duration. "N123AB squawked 7700
for 22 minutes" is the row. The forty positions in between are not.
FOUR THINGS THE LIVE DATA DECIDED
MM, in every column, in a fixed-widthtable.
Number('MM') || 0turns "this buoy has no anemometer" into a flatcalm and "no wave sensor" into a dead-flat sea, and 669 of 853 stations
report no wave height at all. One guard, and null means the buoy did not say.
name=""-- 15009 in the Atlanticarray is one of several. An empty string is not a name, and left as one it
beats the fallback and titles the row with nothing at all. That was visible
in the first smoke run as rows titled ": marine observation".
saying nothing, and classifying it as "windswell" states something about the
water nobody measured. Under two seconds, the period is left out.
/v2/milfar harder than the squawk lists: it answered429 while
/sqk/7700beside it answered 200. A limit is not a failure, so itreturns no items and asks to be called back, which also keeps the cursor
intact -- a run that threw there would leave every open episode untouched and
then report them all as ended on the run after.
ALSO CORRECTED
The comment added in #38 said the NTSB reader slices its output because
upsertItemssends every row in one statement. That is wrong:runSourcealready chunks writes into batches of 200. The slicing is still right, for the
reasons now stated -- 140 MB of narrative text held in memory, and the
four-minute ingest deadline -- but the stated reason was not the real one.
Verified live: 853 buoy observations with 184 reporting waves and one station
over 2.5 m; 40 Pacific and 23 Hawaii surf forecasts with the Honolulu high surf
advisory correctly tagged; all three emergency squawk lists answering with zero
aircraft, which is the correct answer. 596 tests pass, biome clean.
🤖 Generated with Claude Code
https://claude.ai/code/session_01CjTtJPEpyJbvPeQcVfYPPs