LIVE 3
Level
Pipeline
Search
☓ Reset
flowforge-logs — all pipelines — level: ALL 63 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:22 inventory_sync #1042 INFO Job started by scheduler (trigger: cron 0 */2 * * *)
2026-04-04 02:00:22 inventory_sync #1042 INFO Sending GET /v2/products?page=1&per_page=500 to api.supplier.io
2026-04-04 02:00:23 inventory_sync #1042 OK API responded 200 OK500 records page 1
2026-04-04 02:00:24 inventory_sync #1042 INFO Sending GET /v2/products?page=2&per_page=500
2026-04-04 02:00:25 inventory_sync #1042 OK Extraction complete1,240 products received
2026-04-04 02:00:25 inventory_sync #1042 INFO Applying transformation: map_fields
2026-04-04 02:00:25 inventory_sync #1042 INFO Applying transformation: filter_inactive — 39 rows removed
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
PAGE 1 OF 3 — 63 RECORDS

▶ Live Tail streaming

live tail — all pipelines