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)
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
