summaryrefslogtreecommitdiff
path: root/priv/repo/migrations/20231107200724_consolidate_email_queues.exs
diff options
context:
space:
mode:
Diffstat (limited to 'priv/repo/migrations/20231107200724_consolidate_email_queues.exs')
-rw-r--r--priv/repo/migrations/20231107200724_consolidate_email_queues.exs9
1 files changed, 9 insertions, 0 deletions
diff --git a/priv/repo/migrations/20231107200724_consolidate_email_queues.exs b/priv/repo/migrations/20231107200724_consolidate_email_queues.exs
new file mode 100644
index 000000000..63f5af369
--- /dev/null
+++ b/priv/repo/migrations/20231107200724_consolidate_email_queues.exs
@@ -0,0 +1,9 @@
+defmodule Pleroma.Repo.Migrations.ConsolidateEmailQueues do
+ use Ecto.Migration
+
+ def change do
+ execute(
+ "UPDATE oban_jobs SET queue = 'mailer' WHERE queue in ('digest_emails', 'new_users_digest')"
+ )
+ end
+end