The GitHub Actions job "Tests (AMD)" on 
airflow.git/asset-state-store-accessors-len-iter has failed.
Run started by GitHub user 1fanwang (triggered by 1fanwang).

Head commit for run:
29c75182e651532d2cb19dca61ec3ff2e093cdc3 / 1fanwang <[email protected]>
Let a caller size and iterate AssetStateStoreAccessors

The accessors only expose the single-accessor shorthand, which raises when the
caller serves more than one asset. A task knows its own inlets, but a caller
that is handed the accessors does not, and the triggerer hands them to every
BaseEventTrigger that has asset watchers. Triggers are deduplicated by
hash(classpath, kwargs) while asset_watcher is many-to-many, so a trigger
watched by two assets receives two accessors.

Detecting that today means catching the ValueError, which a state store backend
can also raise, so the catch can hide a real failure. Add __len__ to ask
directly and __iter__ so such a caller can address every asset in turn rather
than giving up on per asset state.

Signed-off-by: 1fanwang <[email protected]>

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

With regards,
GitHub Actions via GitBox


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

Reply via email to