Alex Poliakov apoliakov
apoliakov
/ dbos_observability.sql
Last active
January 23, 2026 02:40
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
| -- Queries for worker-centric DBOS Observability | |
| -- Many of these are supported by the DBOS Conductor UI | |
| -- https://docs.dbos.dev/production/conductor | |
| -- For questions, reach out to alex.poliakov@dbos.dev | |
| -- DBOS assigns each worker an `executor_id` when it starts. You can set the custom ID in DBOS config: | |
| -- https://docs.dbos.dev/python/reference/configuration | |
| -- This query returns all workflows that are currently running on each worker by executor_id | |
| -- 1. Query what executors are doing at any given time |
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
| WITH daily_workflows AS ( | |
| SELECT | |
| DATE_TRUNC('day', TO_TIMESTAMP(created_at / 1000)) AS day, | |
| workflow_uuid | |
| FROM dbos.workflow_status | |
| ) | |
| SELECT | |
| dw.day, | |
| COUNT(DISTINCT dw.workflow_uuid) AS workflow_count, | |
| COUNT(oo.workflow_uuid) AS step_count, |