Created
October 17, 2025 13:43
-
-
Save ijunaid8989/245d40d62e9dd939062f16002be7ada8 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| iex(6)> DashboardApi.Workers.MessageDetailsBackfill.enqueue | |
| {:ok, | |
| %Oban.Job{ | |
| __meta__: #Ecto.Schema.Metadata<:loaded, "public", "oban_jobs">, | |
| id: 9, | |
| state: "available", | |
| queue: "message_details_backfill", | |
| worker: "DashboardApi.Workers.MessageDetailsBackfill", | |
| args: %{}, | |
| meta: %{}, | |
| tags: [], | |
| errors: [], | |
| attempt: 0, | |
| attempted_by: nil, | |
| max_attempts: 3, | |
| priority: 0, | |
| attempted_at: nil, | |
| cancelled_at: nil, | |
| completed_at: nil, | |
| discarded_at: nil, | |
| inserted_at: ~U[2025-10-17 13:24:49.916414Z], | |
| scheduled_at: ~U[2025-10-17 13:24:49.916414Z], | |
| conf: nil, | |
| conflict?: false, | |
| replace: nil, | |
| unique: nil, | |
| unsaved_error: nil | |
| }} | |
| [debug] QUERY OK db=13.4ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE true | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: 0cd0695f-8678-453c-a95b-6d55a7b89621 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=10.7ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > '0cd0695f-8678-453c-a95b-6d55a7b89621' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: 1aaa3365-d40f-430f-8fab-b6f760a7ffe3 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=7.4ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > '1aaa3365-d40f-430f-8fab-b6f760a7ffe3' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: 26d07d1c-4881-4fca-8e15-7dbc19f34726 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=6.7ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > '26d07d1c-4881-4fca-8e15-7dbc19f34726' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: 309ec843-1fee-4d12-80c8-98ec3d34490c line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=6.8ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > '309ec843-1fee-4d12-80c8-98ec3d34490c' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: 4166183b-907e-49fa-8a76-9292b5189cc6 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=4.4ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > '4166183b-907e-49fa-8a76-9292b5189cc6' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: 4e928ee3-7ed0-4f90-87e7-406b9a5c9ab0 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=1.1ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > '4e928ee3-7ed0-4f90-87e7-406b9a5c9ab0' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: 58d7fc24-74d6-4865-b737-951eb0bcb687 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=4.1ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > '58d7fc24-74d6-4865-b737-951eb0bcb687' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: 67df5c35-3006-4d4e-890e-dd38cddfba6c line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=4.1ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > '67df5c35-3006-4d4e-890e-dd38cddfba6c' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: 78782018-3d08-4fc7-b953-df32864237c4 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=4.3ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > '78782018-3d08-4fc7-b953-df32864237c4' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: 82e92ba8-47ca-4e5c-ac28-51281f76026a line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=6.0ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > '82e92ba8-47ca-4e5c-ac28-51281f76026a' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: 912d6d5f-e98f-444a-aaab-7264ae6e15f0 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=6.9ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > '912d6d5f-e98f-444a-aaab-7264ae6e15f0' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: 9915a8a6-c8b8-483d-b69e-c376afed9635 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=4.1ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > '9915a8a6-c8b8-483d-b69e-c376afed9635' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: a323adb1-a8e1-47ff-9db3-41edf4f7704c line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=4.6ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > 'a323adb1-a8e1-47ff-9db3-41edf4f7704c' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: b347a384-cafa-4b6f-8a6f-bf573bfaa317 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=3.8ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > 'b347a384-cafa-4b6f-8a6f-bf573bfaa317' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: c45b9063-d640-4803-95bd-98c6e9a74542 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=3.7ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > 'c45b9063-d640-4803-95bd-98c6e9a74542' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: d392f859-8e41-4b6e-bb7c-7e9309e0f43d line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=3.5ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > 'd392f859-8e41-4b6e-bb7c-7e9309e0f43d' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: dd1f4de2-2f4c-4d0b-ae8a-376ec4c3c8c7 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=3.8ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > 'dd1f4de2-2f4c-4d0b-ae8a-376ec4c3c8c7' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: e7d56dbf-0d63-4cf7-a3fb-85c94ce6faad line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=3.5ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > 'e7d56dbf-0d63-4cf7-a3fb-85c94ce6faad' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: f2e8cc1e-d3fb-42a2-ba2f-8dd040c0dc99 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=3.5ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > 'f2e8cc1e-d3fb-42a2-ba2f-8dd040c0dc99' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Processed batch. New cursor: fd657912-43ca-4a13-b54b-643e5bf3b928 line=72 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [debug] QUERY OK db=1.9ms | |
| WITH batch AS ( | |
| SELECT message_id | |
| FROM message_details_records | |
| WHERE message_id > 'fd657912-43ca-4a13-b54b-643e5bf3b928' | |
| ORDER BY message_id | |
| LIMIT 10 | |
| ) | |
| UPDATE messages m | |
| SET | |
| segments = mdr.segments, | |
| sent_at = mdr.sent_at, | |
| delivered_at = mdr.delivered_at, | |
| failed_at = mdr.failed_at | |
| FROM message_details_records mdr | |
| WHERE m.id = mdr.message_id | |
| AND m.id IN (SELECT message_id FROM batch) | |
| RETURNING m.id; | |
| line=95 pid=<0.24565.0> file=lib/ecto/dev_logger.ex domain=elixir application=ecto_dev_logger mfa=Ecto.DevLogger.telemetry_handler/4 ansi_color=default_color | |
| [info] [Message Details Backfill] Backfill completed. Final batch: 0 rows line=60 pid=<0.24565.0> file=lib/dashboard_api/workers/message_details_backfill.ex domain=elixir application=dashboard_api mfa=DashboardApi.Workers.MessageDetailsBackfill.process_result/1 | |
| [notice] Reconnecting streaming connection... | |
| pid=<0.2470.0> | |
| [warning] Streaming connection ended pid=<0.24658.0> | |
| [warning] Got DOWN message from shotgun pid with reason: :normal, will retry in 20410 ms | |
| pid=<0.2470.0> | |
| [notice] Reconnecting streaming connection... | |
| pid=<0.2470.0> | |
| [warning] Streaming connection ended pid=<0.26005.0> | |
| [warning] Got DOWN message from shotgun pid with reason: :normal, will retry in 27090 ms | |
| pid=<0.2470.0> | |
| iex(7)> | |
| BREAK: (a)bort (A)bort with dump (c)ontinue (p)roc info (i)nfo | |
| (l)oaded (v)ersion (k)ill (D)b-tables (d)istribution | |
| ^C% junaidsinternational@ api [WHI-8109/add-fields-from-mdr-to-message] | |
| % | |
| junaidsinternational@ api [WHI-8109/add-fields-from-mdr-to-message] | |
| % | |
| junaidsinternational@ api [WHI-8109/add-fields-from-mdr-to-message] | |
| % git status | |
| On branch WHI-8109/add-fields-from-mdr-to-message | |
| Changes not staged for commit: | |
| (use "git add <file>..." to update what will be committed) | |
| (use "git restore <file>..." to discard changes in working directory) | |
| modified: config/config.exs | |
| modified: lib/dashboard_api/workers/message_details_backfill.ex | |
| n |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment