dheerenmohta opened a new pull request, #72793:
URL: https://github.com/apache/airflow/pull/72793

   `SkipMixin`'s branch/skip decision is written to XCom under a control-plane 
key that the scheduler's `NotPreviouslySkippedDep` reads directly from the 
metadata database, bypassing any configured XCom backend. The task-sdk push 
path didn't carve out the same exception: a custom backend that externalizes 
values (e.g. to blob storage) could leave the scheduler holding an opaque 
pointer instead of the real decision, or fail outright resolving credentials 
the scheduler process doesn't have — silently breaking skip propagation to 
downstream tasks once they are mapped or cleared.
   
   This bypasses the configured backend for that one control-plane key on both 
the sync and async push paths, writing it straight to the metadata DB the same 
way operator extra links already do. The async path needed its own async-safe 
DB-write helper rather than reusing the sync one directly, since the existing 
sync helper blocks on the supervisor comms channel in a way that can deadlock 
if called from the event loop thread.
   
   closes: #50491
   
   ---
   
   ##### Was generative AI tooling used to co-author this PR?
   
   - [X] Yes — Claude Code (Sonnet 5)
   
   Generated-by: Claude Code (Sonnet 5) following [the 
guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions)
   


-- 
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]

Reply via email to