diff options
| author | lain <lain@soykaf.club> | 2019-05-08 18:09:07 +0200 |
|---|---|---|
| committer | lain <lain@soykaf.club> | 2019-05-08 18:09:07 +0200 |
| commit | 6d19bb4eae43270099a68f749519ba0f323da01a (patch) | |
| tree | 3a9466137298d0c25f5bbb436eec7a9079c99711 /lib/pleroma/conversation.ex | |
| parent | a4598b5e8bc640ffc1a052438e21f3573ff837ee (diff) | |
| download | pleroma-6d19bb4eae43270099a68f749519ba0f323da01a.tar.gz | |
Conversations: Add mix task to 'import' old DMs.
Diffstat (limited to 'lib/pleroma/conversation.ex')
| -rw-r--r-- | lib/pleroma/conversation.ex | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/lib/pleroma/conversation.ex b/lib/pleroma/conversation.ex index aa73edd75..10c2403e8 100644 --- a/lib/pleroma/conversation.ex +++ b/lib/pleroma/conversation.ex @@ -81,9 +81,12 @@ defmodule Pleroma.Conversation do Pleroma.Web.ActivityPub.ActivityPub.fetch_direct_messages_query() |> Repo.stream() - Repo.transaction(fn -> - stream - |> Enum.each(&create_or_bump_for/1) - end) + Repo.transaction( + fn -> + stream + |> Enum.each(&create_or_bump_for/1) + end, + timeout: :infinity + ) end end |