update job config

Author: zcesur

config/config.exs

@@ -58,7 +58,7 @@ config :algora, Oban,
     activity_mailer: 1,
     activity_discord: 10,
     campaign_emails: 1,
-    fetch_top_contributions: 3,
+    fetch_top_contributions: 1,
     sync_contribution: 3
   ]
 

lib/algora/admin/admin.ex

@@ -27,6 +27,7 @@ defmodule Algora.Admin do
       User
       |> where([u], not is_nil(u.handle))
       |> where([u], not is_nil(u.provider_login))
+      |> where([u], u.type == :individual)
       |> where([u], fragment("not exists (select 1 from user_contributions where user_contributions.user_id = ?)", u.id))
 
     query =
@@ -38,21 +39,25 @@ defmodule Algora.Admin do
 
     Repo.transaction(
       fn ->
-        query
-        |> Repo.stream()
-        |> Enum.each(fn user ->
-          if opts[:dry_run] do
-            IO.puts("Enqueued job for #{user.provider_login}")
-          else
+        if opts[:dry_run] do
+          query
+          |> Repo.stream()
+          |> Enum.to_list()
+          |> length()
+          |> IO.puts()
+        else
+          query
+          |> Repo.stream()
+          |> Enum.each(fn user ->
             %{provider_login: user.provider_login}
             |> Workspace.Jobs.FetchTopContributions.new()
             |> Oban.insert()
             |> case do
               {:ok, _job} -> IO.puts("Enqueued job for #{user.provider_login}")
               {:error, error} -> IO.puts("Failed to enqueue job for #{user.provider_login}: #{inspect(error)}")
             end
-          end
-        end)
+          end)
+        end
       end,
       timeout: :infinity
     )

lib/algora/workspace/jobs/fetch_top_contributions.ex

@@ -11,5 +11,5 @@ defmodule Algora.Workspace.Jobs.FetchTopContributions do
     Algora.Workspace.fetch_top_contributions_async(provider_login)
   end
 
-  def timeout(_), do: :timer.seconds(10)
+  def timeout(_), do: :timer.seconds(30)
 end