fix ScheduledActivity

1 files changed, 12 insertions, 5 deletions

diff --git a/lib/pleroma/scheduled_activity.ex b/lib/pleroma/scheduled_activity.ex
index ea78dce6a..d01100702 100644
--- a/lib/pleroma/scheduled_activity.ex
+++ b/lib/pleroma/scheduled_activity.ex
@@ -119,11 +119,7 @@ defmodule Pleroma.ScheduledActivity do
   def create(%User{} = user, attrs) do
     Multi.new()
     |> Multi.insert(:scheduled_activity, new(user, attrs))
-    |> Multi.run(:scheduled_activity_job, fn _repo, %{scheduled_activity: activity} ->
-      %{activity_id: activity.id}
-      |> ScheduledActivityWorker.new(scheduled_at: activity.scheduled_at)
-      |> Oban.insert()
-    end)
+    |> maybe_add_jobs(Config.get([ScheduledActivity, :enabled]))
     |> Repo.transaction()
     |> case do
       {:ok, %{scheduled_activity: scheduled_activity}} ->
@@ -134,6 +130,17 @@ defmodule Pleroma.ScheduledActivity do
     end
   end
 
+  defp maybe_add_jobs(multi, true) do
+    multi
+    |> Multi.run(:scheduled_activity_job, fn _repo, %{scheduled_activity: activity} ->
+      %{activity_id: activity.id}
+      |> ScheduledActivityWorker.new(scheduled_at: activity.scheduled_at)
+      |> Oban.insert()
+    end)
+  end
+
+  defp maybe_add_jobs(multi, _), do: multi
+
   def get(%User{} = user, scheduled_activity_id) do
     ScheduledActivity
     |> where(user_id: ^user.id)