From: Alexander Strizhakov <alex.strizhakov@gmail.com>
Date: Fri, 4 Sep 2020 09:05:17 +0000 (+0300)
Subject: migration fix
X-Git-Url: https://git.squeep.com/?a=commitdiff_plain;h=29c1178c2b20eb1b389c7e1d35b58af05f48e8a2;p=akkoma

migration fix
---

diff --git a/priv/repo/migrations/20200825061316_move_activity_expirations_to_oban.exs b/priv/repo/migrations/20200825061316_move_activity_expirations_to_oban.exs
index 2bfefceb0..137933368 100644
--- a/priv/repo/migrations/20200825061316_move_activity_expirations_to_oban.exs
+++ b/priv/repo/migrations/20200825061316_move_activity_expirations_to_oban.exs
@@ -13,7 +13,7 @@ defmodule Pleroma.Repo.Migrations.MoveActivityExpirationsToOban do
       select: %{id: e.id, activity_id: e.activity_id, scheduled_at: e.scheduled_at}
     )
     |> Pleroma.Repo.stream()
-    |> Enum.each(fn expiration ->
+    |> Stream.each(fn expiration ->
       with {:ok, expires_at} <- DateTime.from_naive(expiration.scheduled_at, "Etc/UTC") do
         Pleroma.Workers.PurgeExpiredActivity.enqueue(%{
           activity_id: FlakeId.to_string(expiration.activity_id),