LIVE 3
Total Pipelines
34
+2 this week
Jobs Run Today
128
+18% vs. yesterday
Success Rate
97.3%
+0.4% vs. last week
📊
Data Processed
1.8 TB
today

▶ Recent Job Runs

View All
Pipeline Source → Dest Status Rows Duration Ran
sales_analytics_daily PostgreSQL → Snowflake ✓ success 82,419 14.2s 12m ago
user_events_stream Kafka → BigQuery ▶ running running 3m ago
inventory_sync REST API → MySQL ✓ success 5,201 6.8s 1h ago
marketing_attribution Segment → Redshift ☓ failed 0 2h ago
product_catalog_export MongoDB → S3 ✓ success 14,320 22.1s 3h ago
finance_ledger_sync MySQL → BigQuery ✓ success 3,488 9.4s 4h ago
crm_contacts_delta Salesforce → PostgreSQL ⚠ partial 9,012 18.6s 5h ago
log_archive Cloudwatch → S3 Glacier ✓ success 441,200 47.3s 6h ago

⚠ Active Alerts

3 open
Pipeline [user_events_stream] — Kafka broker unreachable (attempt 2/3)
4m ago
Pipeline [marketing_attribution] — job failed after 3 retries
2h ago
Pipeline [crm_contacts_delta] — 88 rows skipped due to schema mismatch
5h ago
View All Alerts

■ Today's Throughput

Rows Extracted 1,241,030
Rows Transformed 1,238,881
Rows Loaded 1,238,705
Rows Failed 176

█ Pipeline Health

Manage
Pipeline Success Rate (30d) Last Duration Avg Duration Runs / 30d Next Run
sales_analytics_daily
99.1%
14s 13s 30 02:00 UTC
inventory_sync
97.8%
7s 6s 720 every 2h
user_events_stream
88.2%
45s 2,880 streaming
marketing_attribution
72.5%
28s 30 06:00 UTC
finance_ledger_sync
100.0%
9s 10s 60 every 12h

📄 Live Log Stream live

Full Logs
flowforge-runner — live output