New to Kestra?
Use blueprints to kickstart your first workflows.
Audit Metaplane monitor coverage weekly with Kestra. List every monitor on a connection, disabled included, and post the count to Slack to catch drift.
Monitor coverage erodes quietly. Someone disables a noisy monitor during an incident and forgets to re-enable it; new tables land without anyone extending coverage; a connection gets rebuilt and half its monitors do not come back. This blueprint makes the erosion visible with io.kestra.plugin.metaplane.List: every week it fetches the complete monitor inventory of a connection, disabled monitors included, and posts the headcount to Slack. A number that drifts down between digests is a coverage regression someone can chase before it matters.
list_monitors (io.kestra.plugin.metaplane.List) calls the Metaplane API for every monitor on the connectionId. includeDisabled: true counts monitors that exist but do not run, exactly the ones that erode coverage invisibly.fetchType: FETCH returns the monitors directly as task outputs, an array of monitor objects plus a total count. The alternatives are FETCH_ONE for a single monitor, STORE to write the list to internal storage as a file for large inventories, and NONE.post_digest posts the scalar total to Slack with the connection ID, keeping the message a one-line weekly heartbeat.errors block raises a distinct alert when the inventory itself cannot run, since a missing digest is easy to overlook on a busy Monday.Schedule trigger posts every Monday at 08:00, before the weekly data team sync.An inventory that someone must remember to check is not an inventory, it is a hope. Kestra runs the audit on cadence, keeps every result in the execution history so trends are reconstructable, alerts when the audit itself breaks, and turns the monitor list into structured outputs that downstream tasks can diff, filter, or store. The same flow doubles as an on-demand lookup by executing it manually with a different connection ID.
METAPLANE_API_TOKEN: Metaplane API token.SLACK_WEBHOOK_URL: Slack incoming webhook URL.connection_id input default to a connection UUID from your Metaplane settings.weekly_digest trigger.fetchType: STORE for very large inventories and process the stored ion file downstream.total in Kestra's KV store and alert only when the count drops, turning the digest into a regression detector.fetchGroups: true to include monitor group information when your workspace organizes monitors into groups.