diff --git a/lib/towerops/workers/ai_network_insight_worker.ex b/lib/towerops/workers/ai_network_insight_worker.ex
index 49e7c7e6..8b8a7b87 100644
--- a/lib/towerops/workers/ai_network_insight_worker.ex
+++ b/lib/towerops/workers/ai_network_insight_worker.ex
@@ -32,19 +32,14 @@ defmodule Towerops.Workers.AiNetworkInsightWorker do
 
   @impl Oban.Worker
   def perform(%Oban.Job{}) do
-    case Repo.transaction(fn ->
-           Organization
-           |> select([o], o.id)
-           |> Repo.stream()
-           |> Enum.each(&process_organization/1)
-         end) do
-      {:ok, _} ->
-        :ok
+    org_ids =
+      Organization
+      |> select([o], o.id)
+      |> Repo.all()
 
-      {:error, reason} ->
-        Logger.error("AI network insight transaction failed: #{inspect(reason)}")
-        {:error, reason}
-    end
+    Enum.each(org_ids, &process_organization/1)
+
+    :ok
   end
 
   defp process_organization(organization_id) do