Observability & Logging
Reliable background jobs, simplified.
Full-Stack Visibility for Scheduled Workflows
Track every execution cycle from trigger to completion. CronFlow captures granular runtime data, standardizes output across distributed nodes, and pushes telemetry to your preferred monitoring stack without adding latency to your job queue.
Whether you are debugging a failed invoice_generation task or auditing SLA compliance for the quarterly_data_sync cron, our logging pipeline retains 90 days of execution history by default. All payloads are automatically parsed, indexed, and ready for instant retrieval via the dashboard or REST API.
Structured Output & Instant Filtering
Stop grepping through unstructured text files. CronFlow enforces RFC 3339 timestamps and ISO 8601 formatting across all worker nodes. Stream raw stdout/stderr or parse pre-formatted JSON payloads directly in the console.
Live Execution Stream
Watch job runs unfold in real-time. Filter by status code, queue name, or worker ID. Supports WebSocket streaming for sub-second latency on critical production jobs.
[2024-03-15T14:22:08Z] INFO worker_04 | job_id: 8a7f3c2d | status: completed | duration: 1.42s | payload_size: 24KBStructured JSON Logging
Every execution event emits a deterministic JSON object. Easily ingest into Elasticsearch, Splunk, or your internal data lake without custom parsers.
{"level":"error","ts":"2024-03-15T14:22:11Z","msg":"timeout_exceeded","job":"payment_reconciliation","retry_count":3,"next_retry":"2024-03-15T14:27:11Z"}Metrics That Drive Reliability
Surface queue depth, success rates, and execution latency at a glance. CronFlow exports 40+ native metrics via Prometheus-compatible endpoints and pushes direct traces to Datadog, New Relic, and Grafana Cloud.
Datadog Integration
One-click deployment of the CronFlow DogStatsD agent. Automatically maps job lifecycle events to Datadog APM traces, custom dashboards, and SLO monitoring. Includes pre-built monitor templates for queue_backlog_exceeded and worker_oom_killed alerts.
Prometheus & OpenMetrics
Expose /metrics on any worker endpoint. Track cronflow_jobs_total, cronflow_execution_duration_seconds, and cronflow_queue_depth with native histogram support. Compatible with Thanos, VictoriaMetrics, and standard Prometheus scrapers.
Custom Alerting Rules
Define threshold-based triggers directly in your cronflow.yaml. Route notifications to Slack, PagerDuty, or email when retry exhaustion hits 5 attempts or when average job latency exceeds 3.2 seconds during peak trading hours.