📄 Job Logs
63 entries — showing 25 per page
| Timestamp | Pipeline | Job | Level | Message |
|---|---|---|---|---|
| 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 | OK | Kafka consumer group joined: flowforge-ues-consumer |
| 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:44 | user_events_stream | #1043 | WARN | Broker kafka-1.prod temporarily unavailable — pausing 3s |
| 2026-04-04 02:07:47 | user_events_stream | #1043 | INFO | Reconnected to kafka-1.prod — resuming consumption |
| 2026-04-04 02:08:55 | user_events_stream | #1043 | ERROR | Connection refused: kafka-1.prod:9092 — attempt 1/3 |
| 2026-04-04 02:09:25 | user_events_stream | #1043 | ERROR | Connection refused: kafka-1.prod:9092 — attempt 2/3 (retry in 30s) |
| 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:02 | marketing_attribution | #1044 | OK | Segment API connected — fetching workspace: acme-corp |
| 2026-04-04 06:00:04 | marketing_attribution | #1044 | INFO | Extracting events: page_viewed, ad_clicked — 2026-04-03 |
| 2026-04-04 06:00:08 | marketing_attribution | #1044 | WARN | API rate limit warning: 90% of 1000 req/min reached |
| 2026-04-04 06:00:10 | marketing_attribution | #1044 | ERROR | HTTP 429 Too Many Requests — backing off 60s |
| 2026-04-04 06:01:10 | marketing_attribution | #1044 | ERROR | HTTP 429 Too Many Requests — backing off 120s (attempt 2/3) |
| 2026-04-04 06:03:10 | marketing_attribution | #1044 | ERROR | HTTP 429 Too Many Requests — max retries exceeded |
| 2026-04-04 06:03:10 | marketing_attribution | #1044 | ERROR | Job #1044 FAILED — could not extract source data after 3 attempts |
| 2026-04-04 06:15:00 | crm_contacts_delta | #1045 | INFO | Job started — incremental delta sync from Salesforce |
| 2026-04-04 06:15:01 | crm_contacts_delta | #1045 | OK | Salesforce OAuth2 token refreshed |
| 2026-04-04 06:15:03 | crm_contacts_delta | #1045 | INFO | Fetching contacts modified since 2026-04-04 06:00:00 |
| 2026-04-04 06:15:05 | crm_contacts_delta | #1045 | OK | 312 delta records retrieved |
| 2026-04-04 06:15:05 | crm_contacts_delta | #1045 | INFO | Applying transformation: map_sf_fields |
| 2026-04-04 06:15:06 | crm_contacts_delta | #1045 | WARN | 24 records have unknown LeadSource values — mapped to OTHER |
| 2026-04-04 06:15:06 | crm_contacts_delta | #1045 | INFO | Applying transformation: upsert_by_contact_id |