Skipping unreliable tests (rapidsai#554)

Related to rapidsai#553

Signed-off-by: niranda perera <niranda.perera@gmail.com>

Author: nirandaperera

cpp/tests/streaming/test_shuffler.cpp

@@ -305,6 +305,7 @@ TEST_P(StreamingShuffler, callbacks_1_consumer) {
 }
 
 TEST_P(StreamingShuffler, callbacks_2_consumer) {
+    GTEST_SKIP();  // TODO: Fix this (#553)
     EXPECT_NO_FATAL_FAILURE(run_test([&](auto ch_in, auto ch_out) -> Node {
         return shuffler_nb(
             ctx, stream, std::move(ch_in), std::move(ch_out), op_id, num_partitions, 2
@@ -313,6 +314,7 @@ TEST_P(StreamingShuffler, callbacks_2_consumer) {
 }
 
 TEST_P(StreamingShuffler, callbacks_4_consumer) {
+    GTEST_SKIP();  // TODO: Fix this (#553)
     EXPECT_NO_FATAL_FAILURE(run_test([&](auto ch_in, auto ch_out) -> Node {
         return shuffler_nb(
             ctx, stream, std::move(ch_in), std::move(ch_out), op_id, num_partitions, 4
@@ -336,6 +338,10 @@ class ShufflerAsyncTest
 
     void SetUp() override {
         std::tie(n_threads, n_inserts, n_partitions, n_consumers) = GetParam();
+
+        if (n_consumers > 1)
+            GTEST_SKIP();  // TODO: Fix this (#553)
+
         BaseStreamingFixture::SetUpWithThreads(n_threads);
         GlobalEnvironment->barrier();  // prevent accidental mixup between shufflers