diff --git a/tests/test_silver__blocks_tx_count_missing_7_days.sql b/tests/test_silver__blocks_tx_count_missing_7_days.sql
index 43618e92..1bbaaa78 100644
--- a/tests/test_silver__blocks_tx_count_missing_7_days.sql
+++ b/tests/test_silver__blocks_tx_count_missing_7_days.sql
@@ -13,6 +13,5 @@ FROM
     ON b.block_id = b2.block_id
 WHERE
     b.block_id >= 226000000
-    AND b.block_timestamp BETWEEN CURRENT_DATE - 8
-    AND CURRENT_TIMESTAMP - INTERVAL '12 HOUR'
+    AND b.block_timestamp BETWEEN CURRENT_DATE - 8 AND CURRENT_TIMESTAMP - INTERVAL '12 HOUR'
     AND b2.block_id IS NULL
diff --git a/tests/test_silver__transactions_and_votes_missing_7_days.sql b/tests/test_silver__transactions_and_votes_missing_7_days.sql
index 2861eed9..25eeefdb 100644
--- a/tests/test_silver__transactions_and_votes_missing_7_days.sql
+++ b/tests/test_silver__transactions_and_votes_missing_7_days.sql
@@ -12,8 +12,7 @@ WITH solscan_counts AS (
         JOIN solana.silver.blocks b
         ON b.block_id = s.block_id
     WHERE
-        b.block_timestamp :: DATE BETWEEN CURRENT_DATE - 8
-        AND CURRENT_DATE - INTERVAL '12 HOUR'
+        b.block_timestamp :: DATE BETWEEN CURRENT_DATE - 8 AND CURRENT_DATE - INTERVAL '12 HOUR'
 ),
 silver_counts AS (
     SELECT
@@ -28,8 +27,7 @@ silver_counts AS (
                 {{ ref('silver__transactions') }}
                 t
             WHERE
-                block_timestamp :: DATE BETWEEN CURRENT_DATE - 8
-                AND CURRENT_DATE - INTERVAL '12 HOUR'
+                block_timestamp :: DATE BETWEEN CURRENT_DATE - 8 AND CURRENT_DATE - INTERVAL '12 HOUR'
             UNION
             SELECT
                 block_id,
@@ -37,8 +35,7 @@ silver_counts AS (
             FROM
                 solana.silver.votes t
             WHERE
-                block_timestamp :: DATE BETWEEN CURRENT_DATE - 8
-                AND CURRENT_DATE - INTERVAL '12 HOUR'
+                block_timestamp :: DATE BETWEEN CURRENT_DATE - 8 AND CURRENT_DATE - INTERVAL '12 HOUR'
         )
     GROUP BY
         1
diff --git a/tests/test_streamline__snowflake_tasks_running.sql b/tests/test_streamline__snowflake_tasks_running.sql
new file mode 100644
index 00000000..6cfbdc1e
--- /dev/null
+++ b/tests/test_streamline__snowflake_tasks_running.sql
@@ -0,0 +1,59 @@
+{{
+    config(
+        tags=["test_hourly"]
+    )
+}}
+
+WITH block_txs_real_time_task_counts AS (
+    SELECT 
+        count(*) AS success_count
+    FROM 
+        TABLE(solana.information_schema.task_history(
+            scheduled_time_range_start=>dateadd('hour',-1,current_timestamp()),
+            task_name=>'BULK_GET_BLOCK_TXS_REAL_TIME'))
+    WHERE
+        state = 'SUCCEEDED'
+),
+block_rewards_real_time_task_counts AS (
+    SELECT 
+        count(*) AS success_count
+    FROM 
+        TABLE(solana.information_schema.task_history(
+            scheduled_time_range_start=>dateadd('hour',-1,current_timestamp()),
+            task_name=>'BULK_GET_BLOCK_REWARDS_REAL_TIME'))
+    WHERE
+        state = 'SUCCEEDED'
+),
+blocks_real_time_task_counts AS (
+    SELECT 
+        count(*) AS success_count
+    FROM 
+        TABLE(solana.information_schema.task_history(
+            scheduled_time_range_start=>dateadd('hour',-1,current_timestamp()),
+            task_name=>'BULK_GET_BLOCKS_REAL_TIME'))
+    WHERE
+        state = 'SUCCEEDED'
+)
+SELECT
+    'block_txs_real_time' AS pipeline,
+    success_count
+FROM
+    block_txs_real_time_task_counts
+WHERE
+    success_count < 7
+UNION ALL
+SELECT
+    'blocks_real_time' AS pipeline,
+    success_count
+FROM
+    blocks_real_time_task_counts
+WHERE
+    success_count < 10
+UNION ALL
+SELECT
+    'block_rewards_real_time' AS pipeline,
+    success_count
+FROM
+    block_rewards_real_time_task_counts
+WHERE
+    success_count < 3
\ No newline at end of file