Fix test

Author: ericmj

test/hexdocs/search_test.exs

@@ -142,7 +142,9 @@ defmodule Hexdocs.SearchTest do
     Hexdocs.Store.put!(:repo_bucket, key, tar)
     ref = Broadway.test_message(Hexdocs.Queue, queue_search_message(key))
 
-    assert_receive {:exit, ^ref, [_], {%RuntimeError{message: msg}, _stacktrace}}
+    assert_receive {:ack, ^ref,
+                    [%Broadway.Message{status: {:error, %RuntimeError{message: msg}, _stacktrace}}], []}
+
     assert msg == "Unexpected search_data format for #{package} 1.0.0"
     assert typesense_search(%{"q" => package, "query_by" => "package"}) == []
   end
@@ -158,7 +160,9 @@ defmodule Hexdocs.SearchTest do
     Hexdocs.Store.put!(:repo_bucket, key, tar)
     ref = Broadway.test_message(Hexdocs.Queue, queue_search_message(key))
 
-    assert_receive {:exit, ^ref, [_], {%RuntimeError{message: msg}, _stacktrace}}
+    assert_receive {:ack, ^ref,
+                    [%Broadway.Message{status: {:error, %RuntimeError{message: msg}, _stacktrace}}], []}
+
     assert msg =~ "Failed to decode search data json for #{package} 1.0.0: :unexpected_end"
     assert typesense_search(%{"q" => package, "query_by" => "package"}) == []
   end
@@ -174,7 +178,8 @@ defmodule Hexdocs.SearchTest do
     Hexdocs.Store.put!(:repo_bucket, key, tar)
     ref = Broadway.test_message(Hexdocs.Queue, queue_search_message(key))
 
-    assert_receive {:exit, ^ref, [_], {%RuntimeError{message: msg}, _stacktrace}}
+    assert_receive {:ack, ^ref,
+                    [%Broadway.Message{status: {:error, %RuntimeError{message: msg}, _stacktrace}}], []}
 
     assert msg ==
              "Failed to extract search items and proglang from search data for #{package} 1.0.0"
@@ -193,7 +198,8 @@ defmodule Hexdocs.SearchTest do
     Hexdocs.Store.put!(:repo_bucket, key, tar)
     ref = Broadway.test_message(Hexdocs.Queue, queue_search_message(key))
 
-    assert_receive {:exit, ^ref, [_], {%RuntimeError{message: msg}, _stacktrace}}
+    assert_receive {:ack, ^ref,
+                    [%Broadway.Message{status: {:error, %RuntimeError{message: msg}, _stacktrace}}], []}
 
     assert msg ==
              "Failed to extract search items and proglang from search data for #{package} 1.0.0"
@@ -220,7 +226,9 @@ defmodule Hexdocs.SearchTest do
     Hexdocs.Store.put!(:repo_bucket, key, tar)
     ref = Broadway.test_message(Hexdocs.Queue, queue_search_message(key))
 
-    assert_receive {:exit, ^ref, [_], {%RuntimeError{message: msg}, _stacktrace}}
+    assert_receive {:ack, ^ref,
+                    [%Broadway.Message{status: {:error, %RuntimeError{message: msg}, _stacktrace}}], []}
+
     assert msg =~ "Failed to index search item for #{package} 1.0.0 for document "
     assert msg =~ "Field `doc` has been declared in the schema, but is not found in the document."
   end
@@ -246,7 +254,9 @@ defmodule Hexdocs.SearchTest do
     Hexdocs.Store.put!(:repo_bucket, key, tar)
     ref = Broadway.test_message(Hexdocs.Queue, queue_search_message(key))
 
-    assert_receive {:exit, ^ref, [_], {%RuntimeError{message: msg}, _stacktrace}}
+    assert_receive {:ack, ^ref,
+                    [%Broadway.Message{status: {:error, %RuntimeError{message: msg}, _stacktrace}}], []}
+
     assert msg =~ "Failed to index search item for #{package} 1.0.0 for document "
     assert msg =~ "Field `type` must be a string."
   end