diff --git a/accelerators/databricks/scripts/extract_doc_content.py b/accelerators/databricks/scripts/extract_doc_content.py
index f8cf244..206afc8 100644
--- a/accelerators/databricks/scripts/extract_doc_content.py
+++ b/accelerators/databricks/scripts/extract_doc_content.py
@@ -75,6 +75,10 @@ def run(s3_service: AwsS3Service, vault_service: VaultService, convert_to_parque
             export_doc_response: JobCreateResponse = vault_service.export_document_versions(request_string)
 
             job_id: int = export_doc_response.job_id
+            if job_id is None:
+                log_message(log_level='Error',
+                        message=export_doc_response.errors)
+                raise Exception("An error has occured exporting document versions")
             is_vault_job_finished = False
 
             log_message(log_level='Info',
diff --git a/accelerators/redshift/scripts/extract_doc_content.py b/accelerators/redshift/scripts/extract_doc_content.py
index 80f7a27..b6b7e95 100644
--- a/accelerators/redshift/scripts/extract_doc_content.py
+++ b/accelerators/redshift/scripts/extract_doc_content.py
@@ -75,6 +75,10 @@ def run(s3_service: AwsS3Service, vault_service: VaultService, convert_to_parque
             export_doc_response: JobCreateResponse = vault_service.export_document_versions(request_string)
 
             job_id: int = export_doc_response.job_id
+            if job_id is None:
+                log_message(log_level='Error',
+                        message=export_doc_response.errors)
+                raise Exception("An error has occured exporting document versions")
             is_vault_job_finished = False
 
             log_message(log_level='Info',
diff --git a/accelerators/snowflake/scripts/extract_doc_content.py b/accelerators/snowflake/scripts/extract_doc_content.py
index 854e8df..1dddd40 100644
--- a/accelerators/snowflake/scripts/extract_doc_content.py
+++ b/accelerators/snowflake/scripts/extract_doc_content.py
@@ -74,6 +74,10 @@ def run(s3_service: AwsS3Service, vault_service: VaultService, convert_to_parque
             export_doc_response: JobCreateResponse = vault_service.export_document_versions(request_string)
 
             job_id: int = export_doc_response.job_id
+            if job_id is None:
+                log_message(log_level='Error',
+                        message=export_doc_response.errors)
+                raise Exception("An error has occured exporting document versions")
             is_vault_job_finished = False
 
             log_message(log_level='Info',