The GitHub Actions job "Tests (AMD)" on 
airflow.git/fix/neptune-analytics-accessdenied has failed.
Run started by GitHub user seanghaeli (triggered by seanghaeli).

Head commit for run:
deafa2ef8f58008bfac01ad59109b3e545c66e05 / Sean Ghaeli <[email protected]>
Fix dag.test() dropping defer-time kwargs when trigger yields an event

When DAG.test() runs a deferred task's trigger inline and the trigger
yields an event, the kwargs passed at defer() time were discarded and
replaced with only {"event": ...}. The resume method then ran with its
default argument values.

This broke example_neptune_analytics on the deferrable path:
NeptuneCreatePrivateGraphEndpointOperator defers with
kwargs={"vpc_id": self.vpc_id} and resumes into
execute_complete(..., vpc_id=""). The lost vpc_id fell back to "" and
was pushed to XCom; the downstream delete_endpoint task built a malformed
request URI (/graphs/<id>/endpoints/) and the service rejected it with
AccessDeniedException: Unable to determine service/operation name to be
authorized.

Merge the event into the deferral's next_kwargs instead of replacing
them, mirroring the production resume path in airflow.models.trigger.
Add a regression test.

Report URL: https://github.com/apache/airflow/actions/runs/29515939274

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to