Skip to content
DarkPrint
Aautogendelta-extractor1.0.0

Delta Extractor

Get card

Clone

npx -y darkprint clone delta-extractor@1.0.0

There is no repository and no history behind a card. Download hands you the document as it stands, and Clone fetches the same document by name.

↓ 1 downloads

Query the warehouse for every row changed inside the window and return them as a table, paging at the row cap so one runaway night cannot pull the whole history.

used in 1 blueprint

Specification

107 words · handed to the agent

Query the warehouse for every row whose change timestamp falls inside the window you receive on window, reading in pages of 5000 rows ordered by that timestamp so paging stays stable across the run. Emit the rows on rows over a fixed set of columns, in the order the warehouse returned them, with no reshaping or filtering of your own. Stop at 50000 rows and report the timestamp you stopped at, so a runaway night comes back truncated and resumable instead of pulling the whole history. Issue reads only: you must not write, update or delete anything in the warehouse, whatever the window turns out to contain.

Interfaces

1 in · 1 out

Inputs

1
Inputs declared by this node card
NameData typeRequiredDescription
windowjson requiredThe bounded sweep window handed over by the trigger.

Outputs

1
Outputs declared by this node card
NameData typeDescription
rowstableThe changed rows over a fixed set of columns, in warehouse order.

Dependencies

1

The upstream nodes this card expects to receive from. Whenever a blueprint pins this card, each name is checked against a real edge in that graph. A name without a link is not a published card; it refers to a node inside some graph.

Card values

17 declared

Who the node is. The id is the key the DOT pins.

id
delta-extractor
name
Delta Extractor
type
tool
phases
none declared
Behaviourcard spec →

What it does, and the prose the agent is handed when the graph runs.

action30 words
Query the warehouse for every row changed inside the window and return them as a table, paging at the row cap so one runaway night cannot pull the whole history.
spec107 words
Query the warehouse for every row whose change timestamp falls inside the window you receive on window, reading in pages of 5000 rows ordered by that timestamp so paging stays stable across the run. Emit the rows on rows over a fixed set of columns, in the order the warehouse returned them, with no reshaping or filtering of your own. Stop at 50000 rows and report the timestamp you stopped at, so a runaway night comes back truncated and resumable instead of pulling the whole history. Issue reads only: you must not write, update or delete anything in the warehouse, whatever the window turns out to contain.in full above
model
whatever the graph supplies
agent
Delta extractor
skill
skills/delta-extractor.md
tools
SQL
mcp
postgres
params
max_rows: 50000, page_size: 5000
Interfacescard spec →

What arrives, what leaves, which nodes it expects to hear from, and what may not.

inputs
window : json
outputs
rows : table
dependencies
delta-intake
cannot
no type is refused
will_not
write anything back to the warehouse, reshape the rows it returns
Evaluation metadatacard spec →

The keys the static analysis reads. Nothing here instructs the agent.

risk_markers
none
notes60 words
This node only reads, but the vocabulary's sql capability does not distinguish a read from a write and the analyzer cannot tell the difference. Under ontology v0.1 that shows up as an inferred unvalidated-external-access on every sql node whose consumer is not a validation node, here it is arguably fair, since the rows really do come from outside the graph.
Service fieldscard spec →

The card's own version, and who wrote it.

version
1.0.0
author
autogen
provenance
not stated

Definitions for every card field

Version history

1 version published
  1. delta-extractor@1.0.0currentsha256:3c518b8b10275985217123b3963927b7d037b700f27ebed975dc02adf294b6e5

    pinned byNightly Data Janitorautogen/nightly-data-janitor

A digest is a fingerprint (SHA-256) of the card's content, computed without the author and provenance fields. The same card from two people gets the same digest; any edit gets a new one.

First published version, so there is nothing to compare yet. Versions are never edited in place: the next change arrives as a new version, and the differences between the two documents are listed here.

Community notes (0)

No notes yet.

Nobody has posted about this node card yet.

Sign in to post a note.