diff --git a/airflow/providers/amazon/aws/operators/batch.py b/airflow/providers/amazon/aws/operators/batch.py index 23d245ae7be79..7cf2cbfeacd17 100644 --- a/airflow/providers/amazon/aws/operators/batch.py +++ b/airflow/providers/amazon/aws/operators/batch.py @@ -359,7 +359,12 @@ def monitor_job(self, context: Context): else: self.hook.wait_for_job(self.job_id) - awslogs = self.hook.get_job_all_awslogs_info(self.job_id) + awslogs = [] + try: + awslogs = self.hook.get_job_all_awslogs_info(self.job_id) + except AirflowException as ae: + self.log.warning("Cannot determine where to find the AWS logs for this Batch job: %s", ae) + if awslogs: self.log.info("AWS Batch job (%s) CloudWatch Events details found. Links to logs:", self.job_id) link_builder = CloudWatchEventsLink()