Simplify and unify WATCHER implementation regardless of `InvocationMode`#2498

Merged

tatiana merged 15 commits into

mainfrom

unify-watcher-regardless-of-invocation-mode

Mar 27, 2026

Commits on Mar 23, 2026

First version: unify watcher to always use SUBPROCESS
tatiana
committed
Support both InvocationMode.SUBPROCESS and DBT_RUNNER in WATCHER producer

tatiana
and
claude
committed

Commits on Mar 24, 2026

Try to fix integration tests
tatiana
committed
Fix unittests
tatiana
committed
Address conflicts and make this branch mergeable
tatiana
committed
Address memory utilisation concern raised during PR review
tatiana
committed
Tackle issues while parsing dbt events gracefully, so sensors are not hanging
tatiana
committed
Add interface backward-compatibility. Removing the use_event parameter from WatcherTrigger.__init__ is a compatibility risk for in-flight deferred tasks: triggers serialized before this change may …
tatiana
committed
Fix incorrect signature for write method. matches io.TextIOBase.write(s: str) -> int exactly — data is still discarded, but the contract is correct: callers get back the number of
tatiana
committed
Address copilot concern in https://github.com/astronomer/astronomer-cosmos/pull/2498\#discussion_r2980974306. The fix is to hold xcom_set_lock across the entire pull+append+push. Since safe_xcom_pu…
tatiana
committed
Update cosmos/operators/_watcher/base.py
tatiana
authored

Commits on Mar 25, 2026

Merge branch 'main' into unify-watcher-regardless-of-invocation-mode
tatiana
authored

Commits on Mar 26, 2026