diff --git a/ingest/scripts/call_loculus.py b/ingest/scripts/call_loculus.py
index e4a68d191..3b9d6e911 100644
--- a/ingest/scripts/call_loculus.py
+++ b/ingest/scripts/call_loculus.py
@@ -315,6 +315,7 @@ def get_submitted(config: Config):
     logger.info("Getting previously submitted sequences")
 
     response = make_request(HTTPMethod.GET, url, config, params=params)
+    expected_record_count = int(response.headers["x-total-records"])
 
     entries: list[dict[str, Any]] = []
     try:
@@ -327,6 +328,10 @@ def get_submitted(config: Config):
         logger.error(f"Error decoding JSON from /get-original-metadata: {response_summary}")
         raise ValueError from err
 
+    if len(entries) != expected_record_count:
+        logger.error("Got incomplete original metadata stream")
+        raise ValueError
+
     # Initialize the dictionary to store results
     submitted_dict: dict[str, dict[str, str | list]] = {}