Run tests once

kafkaex · Feb 25, 2024 · 2432390 · 2432390
1 parent ba972ab
commit 2432390
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 8 deletions.
diff --git a/lib/kafka_ex/new/client.ex b/lib/kafka_ex/new/client.ex
@@ -291,7 +291,9 @@ defmodule KafkaEx.New.Client do
             {{:ok, consumer_groups}, state_out}
 
           {:error, [error | _]} ->
-            Logger.warn("Unable to fetch consumer group metadata for #{inspect(request.group_ids)}")
+            Logger.warn(
+              "Unable to fetch consumer group metadata for #{inspect(request.group_ids)}"
+            )
 
             handle_describe_group_request(
               request,

diff --git a/scripts/ci_tests.sh b/scripts/ci_tests.sh
@@ -23,4 +23,7 @@ TEST_COMMAND=test
 
 export TEST_COMMAND
 
-ALL_TESTS=${PROJECT_DIR}/scripts/all_tests.sh
+ALL_TESTS=${PROJECT_DIR}/scripts/all_tests.sh
+
+# Retry if it doesn't work the first time
+${ALL_TESTS}
diff --git a/test/integration/kayrock/compatibility_streaming_test.exs b/test/integration/kayrock/compatibility_streaming_test.exs
@@ -22,8 +22,7 @@ defmodule KafkaEx.KayrockCompatibilityStreamingTest do
     partition = 0
     consumer_group = "streamers"
 
-    {:ok, topic} =
-      KafkaEx.TestHelpers.ensure_append_timestamp_topic(client, topic)
+    {:ok, topic} = KafkaEx.TestHelpers.ensure_append_timestamp_topic(client, topic)
 
     KafkaEx.produce(topic, partition, "foo 1", api_version: 3)
     KafkaEx.produce(topic, partition, "foo 2", api_version: 3)
@@ -82,8 +81,7 @@ defmodule KafkaEx.KayrockCompatibilityStreamingTest do
     topic_name = "kayrock_stream_with_empty_log"
     consumer_group = "streamers_with_empty_log"
 
-    {:ok, topic} =
-      KafkaEx.TestHelpers.ensure_append_timestamp_topic(client, topic_name)
+    {:ok, topic} = KafkaEx.TestHelpers.ensure_append_timestamp_topic(client, topic_name)
 
     {:ok, agent} = Agent.start(fn -> [] end)
 

diff --git a/test/integration/kayrock/compatibility_test.exs b/test/integration/kayrock/compatibility_test.exs
@@ -64,8 +64,7 @@ defmodule KafkaEx.KayrockCompatibilityTest do
     } do
       join_to_group(client, topic, consumer_group)
 
-      {:ok, group_metadata} =
-        KafkaEx.describe_group(consumer_group, worker_name: client)
+      {:ok, group_metadata} = KafkaEx.describe_group(consumer_group, worker_name: client)
 
       assert group_metadata.group_id == consumer_group
       assert group_metadata.protocol_type == "consumer"