diff --git a/servicex/query_cache.py b/servicex/query_cache.py
index 0a3550bd..81d9ad0e 100644
--- a/servicex/query_cache.py
+++ b/servicex/query_cache.py
@@ -197,7 +197,9 @@ def cached_queries(self) -> List[TransformedResults]:
         with self.lock:
             result = [
                 TransformedResults(**doc)
-                for doc in self.db.search(transforms.request_id.exists())
+                for doc in self.db.search(
+                    transforms.request_id.exists() & ~(transforms.status == "SUBMITTED")
+                )
             ]
         return result
 
diff --git a/tests/test_query_cache.py b/tests/test_query_cache.py
index 3c9de9f9..f557e4a7 100644
--- a/tests/test_query_cache.py
+++ b/tests/test_query_cache.py
@@ -325,6 +325,9 @@ def test_get_transform_request_id(transform_request, completed_status):
         request_id = cache.get_transform_request_id(hash_value)
         assert request_id == "123456"
 
+        # assert that in this state that cached_queries does NOT crash and returns nothing
+        assert len(cache.cached_queries()) == 0
+
         cache.close()