diff --git a/ds-caselaw-ingester/lambda_function.py b/ds-caselaw-ingester/lambda_function.py
index 6e99653..9b5538a 100644
--- a/ds-caselaw-ingester/lambda_function.py
+++ b/ds-caselaw-ingester/lambda_function.py
@@ -17,6 +17,7 @@
     MarklogicApiClient,
     MarklogicResourceNotFoundError,
 )
+from caselawclient.client_helpers import VersionAnnotation, VersionType
 from dotenv import load_dotenv
 from notifications_python_client.notifications import NotificationsAPIClient
 
@@ -375,16 +376,18 @@ def parse_xml(xml) -> ET.Element:
 
 
 def update_judgment_xml(uri, xml) -> bool:
+    annotation = VersionAnnotation(VersionType.SUBMISSION, "updated by ingester")
     try:
         api_client.get_judgment_xml(uri, show_unpublished=True)
-        api_client.save_judgment_xml(uri, xml)
+        api_client.update_document_xml(uri, xml, annotation)
         return True
     except MarklogicResourceNotFoundError:
         return False
 
 
 def insert_document_xml(uri, xml) -> bool:
-    api_client.insert_document_xml(uri, xml)
+    annotation = VersionAnnotation(VersionType.SUBMISSION, "inserted by ingester")
+    api_client.insert_document_xml(uri, xml, annotation)
     return True
 
 
diff --git a/ds-caselaw-ingester/tests.py b/ds-caselaw-ingester/tests.py
index 8aa4945..3ff6928 100644
--- a/ds-caselaw-ingester/tests.py
+++ b/ds-caselaw-ingester/tests.py
@@ -52,8 +52,8 @@ def create_fake_tdr_file(*args, **kwargs):
 
 
 class TestHandler:
-    @patch("lambda_function.api_client")
-    @patch("lambda_function.extract_metadata")
+    @patch("lambda_function.api_client", autospec=True)
+    @patch("lambda_function.extract_metadata", autospec=True)
     @patch("lambda_function.tarfile")
     @patch("lambda_function.boto3.session.Session")
     @patch("lambda_function.urllib3.PoolManager")
@@ -82,8 +82,8 @@ def test_handler_messages_v1(
         assert "Upload Successful" in log
         assert "Ingestion complete" in log
 
-    @patch("lambda_function.api_client")
-    @patch("lambda_function.extract_metadata")
+    @patch("lambda_function.api_client", autospec=True)
+    @patch("lambda_function.extract_metadata", autospec=True)
     @patch("lambda_function.tarfile")
     @patch("lambda_function.boto3.session.Session")
     @patch("lambda_function.urllib3.PoolManager")
@@ -238,7 +238,7 @@ def test_extract_docx_filename_failure(self):
         with pytest.raises(lambda_function.DocxFilenameNotFoundException):
             lambda_function.extract_docx_filename(metadata, "anything")
 
-    @patch("lambda_function.api_client")
+    @patch("lambda_function.api_client", autospec=True)
     def test_store_metadata(self, api_client):
         metadata = {
             "parameters": {
@@ -645,42 +645,42 @@ def test_malformed_message(self):
         with pytest.raises(lambda_function.InvalidMessageException):
             lambda_function.get_consignment_reference(message)
 
-    @patch("lambda_function.api_client")
+    @patch("lambda_function.api_client", autospec=True)
     def test_update_judgment_xml_success(self, api_client):
         xml = ET.XML("<xml>Here's some xml</xml>")
         api_client.get_judgment_xml = MagicMock(return_value=True)
-        api_client.save_judgment_xml = MagicMock(return_value=True)
+        api_client.update_document_xml = MagicMock(return_value=True)
         result = lambda_function.update_judgment_xml("a/fake/uri", xml)
         assert result is True
 
-    @patch("lambda_function.api_client")
+    @patch("lambda_function.api_client", autospec=True)
     def test_update_judgment_xml_judgment_does_not_exist(self, api_client):
         xml = ET.XML("<xml>Here's some xml</xml>")
         api_client.get_judgment_xml = MagicMock(
             side_effect=MarklogicResourceNotFoundError("error")
         )
-        api_client.save_judgment_xml = MagicMock(return_value=True)
+        api_client.update_document_xml = MagicMock(return_value=True)
         result = lambda_function.update_judgment_xml("a/fake/uri", xml)
         assert result is False
 
-    @patch("lambda_function.api_client")
+    @patch("lambda_function.api_client", autospec=True)
     def test_update_judgment_xml_judgment_does_not_save(self, api_client):
         xml = ET.XML("<xml>Here's some xml</xml>")
         api_client.get_judgment_xml = MagicMock(return_value=True)
-        api_client.save_judgment_xml = MagicMock(
+        api_client.update_document_xml = MagicMock(
             side_effect=MarklogicCommunicationError("error")
         )
         with pytest.raises(MarklogicCommunicationError):
             lambda_function.update_judgment_xml("a/fake/uri", xml)
 
-    @patch("lambda_function.api_client")
+    @patch("lambda_function.api_client", autospec=True)
     def test_insert_document_xml_success(self, api_client):
         xml = ET.XML("<xml>Here's some xml</xml>")
         api_client.insert_document_xml = MagicMock(return_value=True)
         result = lambda_function.insert_document_xml("a/fake/uri", xml)
         assert result is True
 
-    @patch("lambda_function.api_client")
+    @patch("lambda_function.api_client", autospec=True)
     def test_insert_document_xml_failure(self, api_client):
         xml = ET.XML("<xml>Here's some xml</xml>")
         api_client.insert_document_xml = MagicMock(
@@ -764,7 +764,7 @@ def test_get_best_xml_with_no_xml_file(self):
             assert result.__class__ == ET.Element
             assert result.tag == "error"
 
-    @patch("lambda_function.api_client")
+    @patch("lambda_function.api_client", autospec=True)
     def test_unpublish_updated_judgment(self, api_client):
         uri = "a/fake/uri"
         api_client.set_published = MagicMock()
diff --git a/requirements/base.txt b/requirements/base.txt
index 6ab46fd..f037215 100644
--- a/requirements/base.txt
+++ b/requirements/base.txt
@@ -1,5 +1,5 @@
 django-environ~=0.10
-ds-caselaw-marklogic-api-client==14.1.0
+ds-caselaw-marklogic-api-client==16.0.0
 requests-toolbelt~=1.0
 urllib3~=1.26
 boto3