diff --git a/test/support/utils.ex b/test/support/utils.ex index 12e63df..d662fa0 100644 --- a/test/support/utils.ex +++ b/test/support/utils.ex @@ -257,7 +257,6 @@ defmodule Klife.TestUtils do offset, opts \\ [] ) do - Process.sleep(500) partition = Keyword.get(opts, :partition, expected_record.partition) iso_lvl = Keyword.get(opts, :isolation, :committed) txn_status = Keyword.get(opts, :txn_status, :committed) @@ -269,8 +268,6 @@ defmodule Klife.TestUtils do :not_found {stored_record, status} -> - assert status == txn_status - Enum.each(Map.from_struct(expected_record), fn {k, v} -> case k do :value -> assert v == stored_record.value @@ -279,6 +276,8 @@ defmodule Klife.TestUtils do _ -> :noop end end) + + assert status == txn_status end end