fix(ingest/sagemaker): handle missing ProcessingInputs field (#6697)

Fixes #6360.
datahub-project · Dec 9, 2022 · c211cfb · c211cfb
1 parent 27ea3bf
commit c211cfb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/metadata-ingestion/src/datahub/ingestion/source/aws/sagemaker_processors/jobs.py b/metadata-ingestion/src/datahub/ingestion/source/aws/sagemaker_processors/jobs.py
@@ -767,7 +767,7 @@ def process_processing_job(self, job: Dict[str, Any]) -> SageMakerJob:
 
         input_datasets = {}
 
-        inputs = job["ProcessingInputs"]
+        inputs = job.get("ProcessingInputs", [])
 
         for input_config in inputs: