LIVE 3
Level
Pipeline
Search
☓ Reset
flowforge-logs — sales_analytics_daily — level: ALL 19 entries
Timestamp Pipeline Job Level Message
2026-04-04 02:00:01 sales_analytics_daily #1041 INFO Job started by scheduler (trigger: cron 0 2 * * *)
2026-04-04 02:00:01 sales_analytics_daily #1041 INFO Connecting to source: PostgreSQL @ db-prod.internal:5432
2026-04-04 02:00:01 sales_analytics_daily #1041 OK Source connection established (23ms)
2026-04-04 02:00:02 sales_analytics_daily #1041 INFO Extracting table: orders — incremental since 2026-04-03 02:00:00
2026-04-04 02:00:04 sales_analytics_daily #1041 INFO Rows extracted: 82,419 from 3 tables
2026-04-04 02:00:04 sales_analytics_daily #1041 INFO Applying transformation: filter_cancelled
2026-04-04 02:00:05 sales_analytics_daily #1041 WARN 14 rows had null shipping_date — filled with order_date
2026-04-04 02:00:05 sales_analytics_daily #1041 INFO Applying transformation: normalize_currency
2026-04-04 02:00:06 sales_analytics_daily #1041 INFO Applying transformation: join_customers
2026-04-04 02:00:08 sales_analytics_daily #1041 INFO Applying transformation: aggregate_daily
2026-04-04 02:00:09 sales_analytics_daily #1041 INFO Connecting to destination: Snowflake PROD_WH
2026-04-04 02:00:10 sales_analytics_daily #1041 OK Destination connection established (156ms)
2026-04-04 02:00:11 sales_analytics_daily #1041 INFO Loading 82,419 rows — batch 1/9
2026-04-04 02:00:13 sales_analytics_daily #1041 INFO Loading 82,419 rows — batch 5/9
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:00 sales_analytics_daily #1041 DEBUG Scheduler evaluated 34 pipelines — 1 due
2026-04-04 02:00:00 sales_analytics_daily #1041 DEBUG Job dispatched to worker pool — worker-03
2026-04-04 02:00:01 sales_analytics_daily #1041 DEBUG Memory usage: 142 MB / 512 MB

▶ Live Tail streaming

live tail — all pipelines