Klavitron Operational Health

Klaviyo write gateway, queue, cache, and job audit status.

Live, refreshed 7 seconds ago

System status

API, worker, SQS, and Klaviyo checks passed

Up

Queue

2 DLQ, oldest job 567s

Watch

Klaviyo

4 retries, 0 active throttles

Watch

Cache

95% suppression on bulk writes

Active

Today

Since midnight ET

Calls received

12,482

+18% vs yesterday

Klaviyo writes

1,934

8,190 cache skips

Success rate

99.6%

4 permanent failures

p95 latency

420ms

worker write path

Needs attention

Most recent first

now 2 Klaviyo job(s) are in the DLQ.

now Oldest Klaviyo queued job is 567 seconds old.

11:31 ET Retry spike on profile.upsert, recovered after backoff.

09:18 ET Klaviyo throttle warning, 3 minute pause applied.

08:44 ET SQLMesh bulk run skipped 8,190 unchanged contacts.

07:02 ET Manual replay completed for 13 failed consent jobs.

Pipeline by source

Current 24 hour window

Source	Calls	Written	Skipped by cache	Failed	p95
SQLMesh	9,420	1,230	8,190	1	420ms
API	2,804	621	2,019	3	180ms
Manual	258	83	112	0	260ms

Time	Source	Type	Identity	Status	Attempts
11:41:22	SQLMesh	profile.upsert	avery@example.com	Completed	1
11:41:19	SQLMesh	list.membership	chris@example.com	Skipped	0
11:40:58	API	consent.update	profile_01HYZ3S4X	Retrying	2
11:39:44	Manual	profile.upsert	jamie@example.com	Failed	5
11:38:07	SQLMesh	property.write	taylor@example.com	Completed	1

2026-05-16 21:25:04.959 INFO cloudwatch

END RequestId: ac35de55-120e-5764-a010-bcd7f0e6d4b7

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.959 INFO cloudwatch

REPORT RequestId: ac35de55-120e-5764-a010-bcd7f0e6d4b7 Duration: 741.80 ms Billed Duration: 742 ms Memory Size: 256 MB Max Memory Used: 143 MB

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.864 INFO cloudwatch

✅ Successfully posted to Slack channel: klavitron-cache

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.731 info cloudwatch

{"event": " \u2705 last_name: current=Wangtrakuldee (str) vs cached=Wangtrakuldee (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.730985Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.731 info cloudwatch

{"event": "\u2705 No change detected for 01K48Q4TZVDA4RNMCRV6JV2DAN (field-level comparison) - hash match: 120dc741c0fc33ea", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.731410Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.731 info cloudwatch

{"event": " \u2705 is_churned_customer: current=False (bool) vs cached=False (bool)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.731207Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.731 info cloudwatch

{"event": " \u2705 purchased_product: current=free_plan (str) vs cached=free_plan (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.731096Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.731 info cloudwatch

{"event": "\u23ed\ufe0f Skipping klaviyo_id:01K48Q4TZVDA4RNMCRV6JV2DAN (canonical_id: 01K48Q4TZVDA4RNMCRV6JV2DAN) - no changes detected (cache hit)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.731537Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.730 info cloudwatch

{"event": " \u2705 first_name: current=Beau (str) vs cached=Beau (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.730875Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.730 info cloudwatch

{"event": " Matching fields in cache (10): ['account_type', 'activation_status', 'first_name', 'goodword_user_id', 'is_churned_customer', 'is_winback', 'last_name', 'phone_number', 'purchased_product', 'subscription_status']...", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.730623Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.730 info cloudwatch

{"event": " Cached fields available (11): ['account_type', 'activation_status', 'email', 'first_name', 'goodword_user_id', 'is_churned_customer', 'is_winback', 'last_name', 'phone_number', 'purchased_product']...", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.730500Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.730 info cloudwatch

{"event": " Current data fields (10): ['account_type', 'activation_status', 'first_name', 'goodword_user_id', 'is_churned_customer', 'is_winback', 'last_name', 'phone_number', 'purchased_product', 'subscription_status']...", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.730358Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.730 info cloudwatch

{"event": "\ud83d\udd0d Cache check for 01K48Q4TZVDA4RNMCRV6JV2DAN:", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.730060Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.730 info cloudwatch

{"event": " \u2705 phone_number: current=****43582821 (str) vs cached=****43582821 (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.730753Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.710 INFO cloudwatch

Transformed 11 fields from 11 input fields

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.710 info cloudwatch

{"event": "\ud83d\udd0d Cache check using post-mapping data: 10 fields", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.710342Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.410 INFO cloudwatch

Airtable field mapping cache invalidated

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.410 INFO cloudwatch

Processing record from sqlmesh_subscription_sync source

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.390 info cloudwatch

{"event": "\ud83d\udd0d Identity resolution: found canonical klaviyo_id 01K48Q4TZVDA4RNMCRV6JV2DAN via cross-ID lookup", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.390166Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.239 info cloudwatch

{"event": "\ud83c\udfaf Processing upsert for klaviyo_id:01K48Q4TZVDA4RNMCRV6JV2DAN (source: sqlmesh_subscription_sync)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.239154Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.239 info cloudwatch

{"event": "\ud83d\udccb Message summary: operation=upsert, source=sqlmesh_subscription_sync, request_id=2903532e-a033-4434-a20d-433809fe9d93, identifier_type=klaviyo_id, identifier=01K48Q4TZVDA4RNMCRV6JV2DAN, field_count=11, profile_preview={\"ACCOUNT_TYPE\": \"paywalled\", \"ACTIVATION_STATUS\": true, \"EMAIL\": \"***uradcliffe@hotmail.com\", \"FIRST_NAME\": \"Beau\", \"GOODWORD_USER_ID\": 1011, \"IS_CHURNED_CUSTOMER\": false, \"IS_WINBACK\": false, \"LAST_NAME\": \"Wangtrakuldee\", \"PHONE\": \"****43582821\", \"PURCHASED_PRODUCT\": \"free_plan\", \"SUBSCRIPTION_STATUS\": \"paywalled\"}", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.238875Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.218 info cloudwatch

{"event": "\ud83d\udd04 Processing SQS message: a7d881fc-8352-4fbd-967c-9818f7728c05", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:04.218841Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:04.217 INFO cloudwatch

START RequestId: ac35de55-120e-5764-a010-bcd7f0e6d4b7 Version: $LATEST

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:03.176 INFO cloudwatch

END RequestId: 76c2835e-6bcd-55c9-a622-e1dc892a1ad9

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:03.176 INFO cloudwatch

REPORT RequestId: 76c2835e-6bcd-55c9-a622-e1dc892a1ad9 Duration: 761.65 ms Billed Duration: 762 ms Memory Size: 256 MB Max Memory Used: 143 MB

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:03.068 INFO cloudwatch

✅ Successfully posted to Slack channel: klavitron-cache

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.931 info cloudwatch

{"event": " \u2705 trial_end: current=2026-03-21T04:58:39Z (str) vs cached=2026-03-21T04:58:39Z (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.931420Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.931 info cloudwatch

{"event": " \u2705 purchased_product: current=Founding Connector Plan (str) vs cached=Founding Connector Plan (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.931528Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.931 info cloudwatch

{"event": "\u2705 No change detected for 01KCT7GGEFPRXGYHJHHCECDR50 (field-level comparison) - hash match: 12ca0b296ba2c5b9", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.931738Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.931 info cloudwatch

{"event": " \u2705 last_name: current=Team (str) vs cached=Team (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.931307Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.931 info cloudwatch

{"event": "\u23ed\ufe0f Skipping klaviyo_id:01KCT7GGEFPRXGYHJHHCECDR50 (canonical_id: 01KCT7GGEFPRXGYHJHHCECDR50) - no changes detected (cache hit)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.931915Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.931 info cloudwatch

{"event": " \u2705 first_name: current=LK (str) vs cached=LK (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.931187Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.931 info cloudwatch

{"event": " \u2705 phone_number: current=****03294727 (str) vs cached=****03294727 (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.931034Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.930 info cloudwatch

{"event": " Cached fields available (12): ['account_type', 'activation_status', 'email', 'first_name', 'goodword_user_id', 'is_churned_customer', 'is_winback', 'last_name', 'phone_number', 'purchased_product']...", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.930691Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.930 info cloudwatch

{"event": " Current data fields (11): ['account_type', 'activation_status', 'first_name', 'goodword_user_id', 'is_churned_customer', 'is_winback', 'last_name', 'phone_number', 'purchased_product', 'subscription_status']...", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.930496Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.930 info cloudwatch

{"event": " Matching fields in cache (11): ['account_type', 'activation_status', 'first_name', 'goodword_user_id', 'is_churned_customer', 'is_winback', 'last_name', 'phone_number', 'purchased_product', 'subscription_status']...", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.930886Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.930 info cloudwatch

{"event": "\ud83d\udd0d Cache check for 01KCT7GGEFPRXGYHJHHCECDR50:", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.930151Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.910 INFO cloudwatch

Transformed 12 fields from 12 input fields

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.910 info cloudwatch

{"event": "\ud83d\udd0d Cache check using post-mapping data: 11 fields", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.910449Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.590 INFO cloudwatch

Airtable field mapping cache invalidated

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.590 INFO cloudwatch

Processing record from sqlmesh_subscription_sync source

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.570 info cloudwatch

{"event": "\ud83d\udd0d Identity resolution: found canonical klaviyo_id 01KCT7GGEFPRXGYHJHHCECDR50 via cross-ID lookup", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.570130Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.430 info cloudwatch

{"event": "\ud83d\udccb Message summary: operation=upsert, source=sqlmesh_subscription_sync, request_id=bf02f2f4-e7e9-4261-adfd-4e7a7fc7dad5, identifier_type=klaviyo_id, identifier=01KCT7GGEFPRXGYHJHHCECDR50, field_count=12, profile_preview={\"ACCOUNT_TYPE\": \"subscriber\", \"ACTIVATION_STATUS\": true, \"EMAIL\": \"***ley@acrewcapital.com\", \"FIRST_NAME\": \"LK\", \"GOODWORD_USER_ID\": 2487, \"IS_CHURNED_CUSTOMER\": false, \"IS_WINBACK\": false, \"LAST_NAME\": \"Team\", \"PHONE\": \"****03294727\", \"PURCHASED_PRODUCT\": \"Founding Connector Plan\", \"SUBSCRIPTION_STATUS\": \"active\", \"TRIAL_END\": \"2026-03-21T04:58:39Z\"}", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.429918Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.430 info cloudwatch

{"event": "\ud83c\udfaf Processing upsert for klaviyo_id:01KCT7GGEFPRXGYHJHHCECDR50 (source: sqlmesh_subscription_sync)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.430189Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.415 info cloudwatch

{"event": "\ud83d\udd04 Processing SQS message: 18e41bb2-0db3-4134-b2b0-35b4944ef2bd", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:25:02.415667Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:25:02.414 INFO cloudwatch

START RequestId: 76c2835e-6bcd-55c9-a622-e1dc892a1ad9 Version: $LATEST

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.271 INFO cloudwatch

REPORT RequestId: 67836906-c627-5013-90fb-0b8424f1669a Duration: 773.73 ms Billed Duration: 774 ms Memory Size: 256 MB Max Memory Used: 143 MB

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.271 INFO cloudwatch

END RequestId: 67836906-c627-5013-90fb-0b8424f1669a

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.146 INFO cloudwatch

✅ Successfully posted to Slack channel: klavitron-cache

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.012 info cloudwatch

{"event": "\u23ed\ufe0f Skipping klaviyo_id:01KHHFD0DYBYG4FYHV9QHHVFCD (canonical_id: 01KHHFD0DYBYG4FYHV9QHHVFCD) - no changes detected (cache hit)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:59.012675Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.012 info cloudwatch

{"event": "\u2705 No change detected for 01KHHFD0DYBYG4FYHV9QHHVFCD (field-level comparison) - hash match: 7ec9ad0a04286dfd", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:59.012550Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.012 info cloudwatch

{"event": " \u2705 last_name: current=Paulose (str) vs cached=Paulose (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:59.011048Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.012 info cloudwatch

{"event": " \u2705 is_churned_customer: current=False (bool) vs cached=False (bool)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:59.012339Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.012 info cloudwatch

{"event": " \u2705 purchased_product: current=free_plan (str) vs cached=free_plan (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:59.012211Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.010 info cloudwatch

{"event": " Current data fields (10): ['account_type', 'activation_status', 'first_name', 'goodword_user_id', 'is_churned_customer', 'is_winback', 'last_name', 'phone_number', 'purchased_product', 'subscription_status']...", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:59.010377Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.010 info cloudwatch

{"event": " Matching fields in cache (10): ['account_type', 'activation_status', 'first_name', 'goodword_user_id', 'is_churned_customer', 'is_winback', 'last_name', 'phone_number', 'purchased_product', 'subscription_status']...", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:59.010640Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.010 info cloudwatch

{"event": " \u2705 first_name: current=Asha (str) vs cached=Asha (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:59.010890Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.010 info cloudwatch

{"event": "\ud83d\udd0d Cache check for 01KHHFD0DYBYG4FYHV9QHHVFCD:", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:59.010075Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.010 info cloudwatch

{"event": " Cached fields available (11): ['account_type', 'activation_status', 'email', 'first_name', 'goodword_user_id', 'is_churned_customer', 'is_winback', 'last_name', 'phone_number', 'purchased_product']...", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:59.010516Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:59.010 info cloudwatch

{"event": " \u2705 phone_number: current=****88526448 (str) vs cached=****88526448 (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:59.010773Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.990 info cloudwatch

{"event": "\ud83d\udd0d Cache check using post-mapping data: 10 fields", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:58.990362Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.990 INFO cloudwatch

Transformed 11 fields from 11 input fields

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.670 INFO cloudwatch

Airtable field mapping cache invalidated

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.670 INFO cloudwatch

Processing record from sqlmesh_subscription_sync source

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.650 info cloudwatch

{"event": "\ud83d\udd0d Identity resolution: found canonical klaviyo_id 01KHHFD0DYBYG4FYHV9QHHVFCD via cross-ID lookup", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:58.650074Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.636 INFO cloudwatch

REPORT RequestId: ba28a665-830d-5900-80bf-c4e761ea4d47 Duration: 2675.20 ms Billed Duration: 2676 ms Memory Size: 256 MB Max Memory Used: 144 MB

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.636 INFO cloudwatch

END RequestId: ba28a665-830d-5900-80bf-c4e761ea4d47

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.513 info cloudwatch

{"extra": {"change_log": {"event_type": "cache_change", "system": "cache", "klaviyo_id": "01KRE7ZWR3J4WDPBBPHDQ1AXPA", "source": "sqlmesh_subscription_sync", "operation": "update", "timestamp": "2026-05-16T21:24:58.494629+00:00", "before": {"fields": {"account_type": "trialer", "trial_days_remaining": "Decimal('10')", "last_name": "Attawar", "trial_end": "2026-05-26T21:04:24", "activation_status": "True", "goodword_user_id": "Decimal('7561')", "is_winback": false, "subscription_status": "trialing", "phone_number": "****78693264", "is_churned_customer": false, "first_name": "Vrij", "purchased_product": "Founding Connector Plan", "email": "***awar.v@gmail.com"}, "data_hash": "d3a474fd2e00c03a05d4762968560b671ff66ae5c428d0bab10ab9e5a536a942"}, "after": {"fields": {"account_type": "trialer", "trial_days_remaining": "Decimal('10')", "last_name": "Attawar", "trial_end": "2026-05-26T21:04:24Z", "activation_status": "True", "goodword_user_id": "Decimal('7561')", "is_winback": false, "subscription_status": "trialing", "phone_number": "****78693264", "is_churned_customer": false, "first_name": "Vrij", "purchased_product": "Founding Connector Plan", "email": "***awar.v@gmail.com"}, "data_hash": "714e31726fa69af38559606f881d22f4d90f63bb5290733a02b6cea52fa51aa3"}, "changes": {"trial_end": {"before": "2026-05-26T21:04:24", "after": "2026-05-26T21:04:24Z"}}, "added_fields": [], "removed_fields": [], "unchanged_fields_count": 12, "context": {"request_id": "8d20a158-5347-4923-a255-a73ace74cfcc"}}}, "event": "\ud83d\udcca Cache update for 01KRE7ZWR3J4WDPBBPHDQ1AXPA: 1 field(s) changed", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:58.494710Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.513 info cloudwatch

{"event": "\ud83d\udcbe Cache updated for 01KRE7ZWR3J4WDPBBPHDQ1AXPA with post-mapping data", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:58.513645Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.510 info cloudwatch

{"event": "\ud83d\udccb Message summary: operation=upsert, source=sqlmesh_subscription_sync, request_id=1075c668-38c0-4b1e-8be6-ac29491447d1, identifier_type=klaviyo_id, identifier=01KHHFD0DYBYG4FYHV9QHHVFCD, field_count=11, profile_preview={\"ACCOUNT_TYPE\": \"paywalled\", \"ACTIVATION_STATUS\": true, \"EMAIL\": \"***a@ashapaulose.com\", \"FIRST_NAME\": \"Asha\", \"GOODWORD_USER_ID\": 2223, \"IS_CHURNED_CUSTOMER\": false, \"IS_WINBACK\": false, \"LAST_NAME\": \"Paulose\", \"PHONE\": \"****88526448\", \"PURCHASED_PRODUCT\": \"free_plan\", \"SUBSCRIPTION_STATUS\": \"paywalled\"}", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:58.509959Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.510 info cloudwatch

{"event": "\ud83c\udfaf Processing upsert for klaviyo_id:01KHHFD0DYBYG4FYHV9QHHVFCD (source: sqlmesh_subscription_sync)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:58.510260Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.498 info cloudwatch

{"event": "\ud83d\udd04 Processing SQS message: 21adce1f-acc3-4e92-9fb0-d703b2151519", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:58.498140Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.496 INFO cloudwatch

START RequestId: 67836906-c627-5013-90fb-0b8424f1669a Version: $LATEST

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.309 info cloudwatch

{"event": "\ud83d\udcbe Updating cache with 13 mapped fields", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:58.309727Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.309 INFO cloudwatch

📊 Klaviyo update for 01KRE7ZWR3J4WDPBBPHDQ1AXPA: 1 field(s) changed

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.224 INFO cloudwatch

Successfully updated profile 01KRE7ZWR3J4WDPBBPHDQ1AXPA

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.074 INFO cloudwatch

Updating 4 changed attributes for 01KRE7ZWR3J4WDPBBPHDQ1AXPA: ['phone_number', 'email', 'first_name', 'last_name']

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:58.074 INFO cloudwatch

Updating 9 changed properties for 01KRE7ZWR3J4WDPBBPHDQ1AXPA: ['trial_end', 'purchased_product', 'is_churned_customer', 'is_winback', 'goodword_user_id', 'trial_days_remaining', 'subscription_status', 'activation_status', 'account_type']

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.989 info cloudwatch

{"event": "\ud83d\udcdd Updating existing profile 01KRE7ZWR3J4WDPBBPHDQ1AXPA (found via KLAVIYO_ID)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.988950Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.988 info cloudwatch

{"event": "\u2705 Found profile using KLAVIYO_ID: 01KRE7ZWR3J4WDPBBPHDQ1AXPA", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.988664Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.876 info cloudwatch

{"event": "\ud83d\udd0d Mapped to Klaviyo fields: ['trial_end', 'purchased_product', 'is_churned_customer', 'phone_number', 'is_winback', 'email', 'goodword_user_id', 'trial_days_remaining', 'first_name', 'subscription_status', 'activation_status', 'last_name', 'account_type']", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.875982Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.876 info cloudwatch

{"event": "\ud83d\udd0d Trying to find profile with KLAVIYO_ID: 01KRE7ZWR3J4WDPBBPHDQ1AXPA", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.876241Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.876 info cloudwatch

{"event": "\ud83d\udd0d Unmapped source fields: ['KLAVIYO_ID']", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.876118Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.875 info cloudwatch

{"event": "\ud83d\udd0d Properties sent to Klaviyo: 13", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.875674Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.836 info cloudwatch

{"event": "\ud83d\udd0d Unmapped fields: 1", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.836143Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.836 info cloudwatch

{"event": "\ud83d\udd0d Mapped 13 fields from 14 input fields", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.835851Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.836 info cloudwatch

{"event": "\ud83d\udd0d Attributes: 4, Properties: 9, Location: 0", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.836274Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.800 INFO cloudwatch

Transformed 13 fields from 14 input fields

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.794 INFO cloudwatch

Processing record from sqlmesh_subscription_sync source

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.793 info cloudwatch

{"event": "\ud83d\udd0d Using FieldMapper for field mapping", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.793702Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.553 INFO cloudwatch

REPORT RequestId: b521531d-a03f-52ce-9f74-319f42d85784 Duration: 733.88 ms Billed Duration: 734 ms Memory Size: 256 MB Max Memory Used: 143 MB

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.553 INFO cloudwatch

END RequestId: b521531d-a03f-52ce-9f74-319f42d85784

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.452 INFO cloudwatch

✅ Successfully posted to Slack channel: klavitron-cache

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.311 info cloudwatch

{"event": " \u2705 purchased_product: current=free_plan (str) vs cached=free_plan (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.310959Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.311 info cloudwatch

{"event": " \u2705 is_winback: current=False (bool) vs cached=False (bool)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.311180Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.311 info cloudwatch

{"event": "\u2705 No change detected for 01KNHXWVV4MZ2XT4WR9KDNAXSM (field-level comparison) - hash match: cf9cd1115a76a91a", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.311376Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.311 info cloudwatch

{"event": "\u23ed\ufe0f Skipping klaviyo_id:01KNHXWVV4MZ2XT4WR9KDNAXSM (canonical_id: 01KNHXWVV4MZ2XT4WR9KDNAXSM) - no changes detected (cache hit)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.311505Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.311 info cloudwatch

{"event": " \u2705 is_churned_customer: current=False (bool) vs cached=False (bool)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.311072Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.310 info cloudwatch

{"event": " \u2705 phone_number: current=****37018309 (str) vs cached=****37018309 (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.310732Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd

2026-05-16 21:24:57.310 info cloudwatch

{"event": " \u2705 first_name: current=Bray (str) vs cached=Bray (str)", "logger": "KlaviyoWorker", "level": "info", "timestamp": "2026-05-16T21:24:57.310849Z"}

queryId=191798f2-c276-4a43-bc02-94f678a728dd