fix invalid args for Tinybird pruner

fastrepl · Oct 29, 2024 · 0d2d0a3 · 0d2d0a3
1 parent 42cd1d4
commit 0d2d0a3
Showing 1 changed file with 8 additions and 9 deletions.
diff --git a/core/lib/canary/workers/project_manager.ex b/core/lib/canary/workers/project_manager.ex
@@ -8,15 +8,14 @@ defmodule Canary.Workers.ProjectManager do
     else
       {:ok, projects} = Ash.read(Canary.Accounts.Project)
 
-      pruner_jobs =
-        projects
-        |> Enum.map(&Canary.Workers.TinybirdPruner.new(%{account_id: &1.id}))
-
-      alias_jobs =
-        projects
-        |> Enum.map(&Canary.Workers.QueryAliases.new(%{project_id: &1.id}))
-
-      Oban.insert_all(pruner_jobs ++ alias_jobs)
+      projects
+      |> Enum.flat_map(fn %{id: id} ->
+        [
+          Canary.Workers.TinybirdPruner.new(%{project_id: id}),
+          Canary.Workers.QueryAliases.new(%{project_id: id})
+        ]
+      end)
+      |> Oban.insert_all()
 
       :ok
     end