diff --git a/astronomer/providers/amazon/aws/extractors/redshift.py b/astronomer/providers/amazon/aws/extractors/redshift.py index 0bbb499ff..8e2f7bd7b 100644 --- a/astronomer/providers/amazon/aws/extractors/redshift.py +++ b/astronomer/providers/amazon/aws/extractors/redshift.py @@ -22,3 +22,4 @@ def _get_xcom_redshift_job_id(self, task_instance: TaskInstance) -> Optional[str redshift_job_id = task_instance.xcom_pull(task_ids=task_instance.task_id, key="return_value") if len(redshift_job_id) > 0: return redshift_job_id[0] + return None