def xcom_pull(
            self,
            context,
            task_ids,
            dag_id=None,