Ignore Kinesis tests

quickwit-oss · Mar 14, 2024 · c8e6ec6 · c8e6ec6
1 parent 63095de
commit c8e6ec6
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/quickwit/quickwit-indexing/src/source/kinesis/api.rs b/quickwit/quickwit-indexing/src/source/kinesis/api.rs
@@ -310,6 +310,7 @@ mod kinesis_localstack_tests {
         wait_for_active_stream, DEFAULT_RETRY_PARAMS,
     };
 
+    #[ignore]
     #[tokio::test]
     async fn test_create_stream() -> anyhow::Result<()> {
         let stream_name = append_random_suffix("test-create-stream");
@@ -326,6 +327,7 @@ mod kinesis_localstack_tests {
         Ok(())
     }
 
+    #[ignore]
     #[tokio::test]
     async fn test_delete_stream() -> anyhow::Result<()> {
         let (kinesis_client, stream_name) = setup("test-delete-stream", 1).await?;
@@ -343,6 +345,7 @@ mod kinesis_localstack_tests {
         Ok(())
     }
 
+    #[ignore]
     #[tokio::test]
     async fn test_get_records() -> anyhow::Result<()> {
         let (kinesis_client, stream_name) = setup("test-get-records", 2).await?;
@@ -450,6 +453,7 @@ mod kinesis_localstack_tests {
         Ok(())
     }
 
+    #[ignore]
     #[tokio::test]
     async fn test_list_shards() -> anyhow::Result<()> {
         let (kinesis_client, stream_name) = setup("test-list-shards", 2).await?;

diff --git a/quickwit/quickwit-indexing/src/source/kinesis/shard_consumer.rs b/quickwit/quickwit-indexing/src/source/kinesis/shard_consumer.rs
@@ -267,6 +267,7 @@ mod tests {
         messages
     }
 
+    #[ignore]
     #[tokio::test]
     async fn test_shard_eof() -> anyhow::Result<()> {
         let universe = Universe::with_accelerated_time();
@@ -307,6 +308,7 @@ mod tests {
         Ok(())
     }
 
+    #[ignore]
     #[tokio::test]
     async fn test_start_at_horizon() -> anyhow::Result<()> {
         let universe = Universe::with_accelerated_time();