Merge remote-tracking branch 'philo/master'

derpibooru · Dec 19, 2024 · baa7ad3 · baa7ad3
2 parents 6346c5f + f2fb468
commit baa7ad3
Showing 1 changed file with 13 additions and 17 deletions.
diff --git a/lib/philomena_query/search.ex b/lib/philomena_query/search.ex
@@ -203,25 +203,21 @@ defmodule PhilomenaQuery.Search do
   def reindex(queryable, module, opts \\ []) do
     index = @policy.index_for(module)
 
-    process =
-      fn records ->
-        lines =
-          Enum.flat_map(records, fn record ->
-            doc = index.as_json(record)
-
-            [
-              %{index: %{_index: index.index_name(), _id: doc.id}},
-              doc
-            ]
-          end)
-
-        Api.bulk(@policy.opensearch_url(), lines)
-      end
-
     queryable
     |> Batch.record_batches(opts)
-    |> Task.async_stream(process, ordered: false, timeout: :infinity)
-    |> Stream.run()
+    |> Enum.each(fn records ->
+      lines =
+        Enum.flat_map(records, fn record ->
+          doc = index.as_json(record)
+
+          [
+            %{index: %{_index: index.index_name(), _id: doc.id}},
+            doc
+          ]
+        end)
+
+      Api.bulk(@policy.opensearch_url(), lines)
+    end)
   end
 
   @doc ~S"""