ignore tests with deps

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(),

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(),

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(),

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(),

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();
 
@@ -351,6 +352,7 @@ async fn basic_pipeline() {
 }
 
 #[tokio::test]
+#[ignore]
 async fn udfs() {
     let udf = r#"
 /*
@@ -438,6 +440,7 @@ async fn delete_topic(client: &AdminClient<impl ClientContext>, topic: &str) {
 }
 
 #[tokio::test]
+#[ignore]
 async fn connection_table() {
     let api_client = get_client();