Widget Functionality

What it does

Visualises the progression of a data pipeline (stages, status, activity) and updates as progress events arrive.

GraphQL operations

• Trigger/start (query):

  • query dataPipeline(progressChannel: String!) { dataPipeline(progressChannel: $progressChannel) { name last_activity_at pipeline_status } }

• Progress updates (subscription):

  • subscription pubsub(channel: String!) { pubsub(channel: $channel) } — emits JSON payloads per progress event.

What you’ll see

• A set of stages with statuses (e.g., running, success, failed) and recent activity.

• As events stream in on the pubsub channel, stage indicators update live.