Taragolis commented on issue #34754: URL: https://github.com/apache/airflow/issues/34754#issuecomment-1765238654
I've unable to reproduce on current main, maybe it already fixed (I can't find related issue/PR) However this one worked as expected ```python from airflow.decorators import task from airflow.models.baseoperator import BaseOperator from airflow.models.dag import DAG from airflow.utils.timezone import datetime from airflow.exceptions import AirflowSkipException @task def make_list(): return [4, 42, 2] class Double(BaseOperator): def __init__(self, x: int, **kwargs): super().__init__(**kwargs) self.x = x def execute(self, context): if self.x == 42: raise AirflowSkipException("42") return self.x * 2 class Result(BaseOperator): def __init__(self, result: int, **kwargs): super().__init__(**kwargs) self.result = result def execute(self, context): print(self.result) with DAG( "issue_34754", start_date=datetime(2023, 10, 1), schedule_interval="@daily", catchup=False, tags=["issue", "34754"] ) as dag: double = Double.partial( task_id="double-int" ).expand(x=make_list()) Result.partial( task_id="print-result", trigger_rule="none_failed" ).expand(result=double.output) ``` ![image](https://github.com/apache/airflow/assets/3998685/e6251fee-ee31-44fe-9192-d02642ca6ffc) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org