diff options
| author | Alexander Strizhakov <alex.strizhakov@gmail.com> | 2020-09-04 12:05:17 +0300 |
|---|---|---|
| committer | rinpatch <rinpatch@sdf.org> | 2020-09-10 21:50:41 +0300 |
| commit | 29c1178c2b20eb1b389c7e1d35b58af05f48e8a2 (patch) | |
| tree | 8bdd4d9050df5857457c22cb7496757a6244b770 | |
| parent | eb5ff715f7917e174b9ae104a5d82779ff925301 (diff) | |
| download | pleroma-29c1178c2b20eb1b389c7e1d35b58af05f48e8a2.tar.gz | |
migration fix
| -rw-r--r-- | priv/repo/migrations/20200825061316_move_activity_expirations_to_oban.exs | 2 |
1 files changed, 1 insertions, 1 deletions
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), |