📄 Job Logs
31 entries — showing 25 per page
| 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: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 | 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: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: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:24 | inventory_sync | #1042 | INFO | Sending GET /v2/products?page=2&per_page=500 |
| 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:03:00 | user_events_stream | #1043 | INFO | Streaming job started — consuming from kafka-1.prod:9092 |
| 2026-04-04 02:03:01 | user_events_stream | #1043 | INFO | Consuming partition 0/3: offset 8,841,230 |
| 2026-04-04 02:03:02 | user_events_stream | #1043 | INFO | Batch 1 — 1,024 events processed and loaded to BigQuery |
| 2026-04-04 02:05:12 | user_events_stream | #1043 | INFO | Batch 44 — 1,024 events processed |
| 2026-04-04 02:07:47 | user_events_stream | #1043 | INFO | Reconnected to kafka-1.prod — resuming consumption |
| 2026-04-04 06:00:00 | marketing_attribution | #1044 | INFO | Job started by scheduler (trigger: cron 0 6 * * *) |
| 2026-04-04 06:00:01 | marketing_attribution | #1044 | INFO | Connecting to Segment Source API |
| 2026-04-04 06:00:04 | marketing_attribution | #1044 | INFO | Extracting events: page_viewed, ad_clicked — 2026-04-03 |
| 2026-04-04 06:15:00 | crm_contacts_delta | #1045 | INFO | Job started — incremental delta sync from Salesforce |