The GitHub Actions job "Tests AMD" on airflow.git/v3-0-test has failed.
Run started by GitHub user kaxil (triggered by kaxil).
Head commit for run:
778823a7a805dbe6e9393fc4b757220dbb1faaba / github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
[v3-0-test] Fix deferred task resumption in ``dag.test()`` (#51182) (#51199)
When using `dag.test()` with deferred tasks, tasks that complete their trigger
execution were incorrectly being set to `SUCCESS` state instead of `SCHEDULED`
state. This prevented task resumption!
Dag used to test:
```python
from datetime import datetime, timedelta, timezone
from typing import Any
import pendulum
from airflow.providers.standard.triggers.temporal import DateTimeTrigger
from airflow.sdk import Context, task, BaseOperator, DAG
class DummyOperator(BaseOperator):
def execute(self, context: Context):
self.defer(
trigger=DateTimeTrigger(
moment=datetime.now(timezone.utc) + timedelta(seconds=2),
),
method_name="execute_complet",
)
def execute_complet(self, context: Context, event: Any = None):
assert event is not None
return "test"
@task
def dummy_task(param):
print("DEBUG")
assert param == "test", "Parameter should be 'test'"
with DAG(
dag_id="example_debug",
start_date=pendulum.datetime(2021, 1, 1, tz="UTC"),
) as dag:
task1 = DummyOperator(task_id="task1")
task2 = dummy_task(task1.output)
task1 >> task2
if __name__ == "__main__":
dag.test()
```
(cherry picked from commit 1b83f7135d4b5167972ec32752642924e8e0a55a)
Co-authored-by: Kaxil Naik <[email protected]>
Report URL: https://github.com/apache/airflow/actions/runs/15325612235
With regards,
GitHub Actions via GitBox
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
