From 6567aa578bd656cd2ffa3b38f8deaa04fea025d3 Mon Sep 17 00:00:00 2001
From: max funk <mxfactorial@users.noreply.github.com>
Date: Sun, 19 May 2024 20:44:17 -0700
Subject: [PATCH] ignore tests with deps

---
 crates/arroyo-connectors/src/kafka/sink/test.rs   | 2 ++
 crates/arroyo-connectors/src/kafka/source/test.rs | 1 +
 crates/arroyo-connectors/src/mqtt/sink/test.rs    | 1 +
 crates/arroyo-connectors/src/mqtt/source/test.rs  | 1 +
 crates/integ/tests/api_tests.rs                   | 3 +++
 5 files changed, 8 insertions(+)

diff --git a/crates/arroyo-connectors/src/kafka/sink/test.rs b/crates/arroyo-connectors/src/kafka/sink/test.rs
index 9d3a34494..f7f22b30e 100644
--- a/crates/arroyo-connectors/src/kafka/sink/test.rs
+++ b/crates/arroyo-connectors/src/kafka/sink/test.rs
@@ -136,6 +136,7 @@ struct KafkaSinkWithWrites {
 }
 
 #[tokio::test]
+#[ignore]
 async fn test_kafka_checkpoint_flushes() {
     let mut kafka_topic_tester = KafkaTopicTester {
         topic: "arroyo-sink-checkpoint".to_string(),
@@ -174,6 +175,7 @@ async fn test_kafka_checkpoint_flushes() {
 }
 
 #[tokio::test]
+#[ignore]
 async fn test_kafka() {
     let mut kafka_topic_tester = KafkaTopicTester {
         topic: "arroyo-sink".to_string(),
diff --git a/crates/arroyo-connectors/src/kafka/source/test.rs b/crates/arroyo-connectors/src/kafka/source/test.rs
index 12404e446..a15a9dfc4 100644
--- a/crates/arroyo-connectors/src/kafka/source/test.rs
+++ b/crates/arroyo-connectors/src/kafka/source/test.rs
@@ -234,6 +234,7 @@ impl KafkaSourceWithReads {
 }
 
 #[tokio::test]
+#[ignore]
 async fn test_kafka() {
     let mut kafka_topic_tester = KafkaTopicTester {
         topic: "__arroyo-source-test".to_string(),
diff --git a/crates/arroyo-connectors/src/mqtt/sink/test.rs b/crates/arroyo-connectors/src/mqtt/sink/test.rs
index 6c2e17678..a01896aac 100644
--- a/crates/arroyo-connectors/src/mqtt/sink/test.rs
+++ b/crates/arroyo-connectors/src/mqtt/sink/test.rs
@@ -106,6 +106,7 @@ struct MqttSinkWithWrites {
 }
 
 #[tokio::test]
+#[ignore]
 async fn test_mqtt() {
     let mqtt_tester = MqttTopicTester {
         topic: "mqtt-arroyo-test-sink".to_string(),
diff --git a/crates/arroyo-connectors/src/mqtt/source/test.rs b/crates/arroyo-connectors/src/mqtt/source/test.rs
index 38f4fe65e..96940a700 100644
--- a/crates/arroyo-connectors/src/mqtt/source/test.rs
+++ b/crates/arroyo-connectors/src/mqtt/source/test.rs
@@ -171,6 +171,7 @@ impl MqttTopicTester {
 }
 
 #[tokio::test]
+#[ignore]
 async fn test_mqtt() {
     let mqtt_tester = MqttTopicTester {
         topic: "mqtt-arroyo-test".to_string(),
diff --git a/crates/integ/tests/api_tests.rs b/crates/integ/tests/api_tests.rs
index d8e806e7c..acca74758 100644
--- a/crates/integ/tests/api_tests.rs
+++ b/crates/integ/tests/api_tests.rs
@@ -179,6 +179,7 @@ async fn patch_and_wait(
 }
 
 #[tokio::test]
+#[ignore]
 async fn basic_pipeline() {
     let api_client = get_client();
 
@@ -347,6 +348,7 @@ async fn basic_pipeline() {
 }
 
 #[tokio::test]
+#[ignore]
 async fn udfs() {
     let udf = r#"
 /*
@@ -434,6 +436,7 @@ async fn delete_topic(client: &AdminClient<impl ClientContext>, topic: &str) {
 }
 
 #[tokio::test]
+#[ignore]
 async fn connection_table() {
     let api_client = get_client();