LIVE 3
Level
Pipeline
Search
☓ Reset
flowforge-logs — all pipelines — level: OK 17 entries
Timestamp Pipeline Job Level Message
2026-04-04 02:00:01 sales_analytics_daily #1041 OK Source connection established (23ms)
2026-04-04 02:00:10 sales_analytics_daily #1041 OK Destination connection established (156ms)
2026-04-04 02:00:15 sales_analytics_daily #1041 OK Load complete82,419 rows written in 8.8s
2026-04-04 02:00:15 sales_analytics_daily #1041 OK Job #1041 SUCCESS — total duration 14.2s
2026-04-04 02:00:23 inventory_sync #1042 OK API responded 200 OK500 records page 1
2026-04-04 02:00:25 inventory_sync #1042 OK Extraction complete1,240 products received
2026-04-04 02:00:26 inventory_sync #1042 OK Upserted 1,201 rows into products table — 0 failed
2026-04-04 02:00:29 inventory_sync #1042 OK Job #1042 SUCCESS — total duration 6.8s
2026-04-04 02:03:01 user_events_stream #1043 OK Kafka consumer group joined: flowforge-ues-consumer
2026-04-04 06:00:02 marketing_attribution #1044 OK Segment API connected — fetching workspace: acme-corp
2026-04-04 06:15:01 crm_contacts_delta #1045 OK Salesforce OAuth2 token refreshed
2026-04-04 06:15:05 crm_contacts_delta #1045 OK 312 delta records retrieved
2026-04-04 06:15:09 crm_contacts_delta #1045 OK 300 rows upserted12 skipped
2026-04-04 06:00:02 finance_ledger_sync #1046 OK Source MySQL connected — reading transactions table
2026-04-04 06:00:07 finance_ledger_sync #1046 OK PII fields anonymised (SHA-256 + salt)
2026-04-04 06:00:08 finance_ledger_sync #1046 OK 3,488 rows loaded into BigQuery finance.ledger_staging
2026-04-04 06:00:09 finance_ledger_sync #1046 OK Job #1046 SUCCESS — duration 9.4s

▶ Live Tail streaming

live tail — all pipelines