msumit commented on code in PR #71220:
URL: https://github.com/apache/airflow/pull/71220#discussion_r3860353043
##########
airflow-core/src/airflow/models/pool.py:
##########
@@ -92,6 +92,26 @@ class Pool(Base):
def __repr__(self):
return str(self.pool)
+ @staticmethod
+ def get_include_deferred_override() -> bool | None:
+ """
+ Get the cluster-wide ``include_deferred`` value fixed via config, if
any.
+
+ When ``[core] pool_include_deferred`` is set, its value applies to
every pool and takes
+ precedence over the per-pool ``include_deferred`` column. Returns None
when unset.
+ """
+ from airflow.configuration import conf
+
+ if conf.get("core", "pool_include_deferred", fallback=""):
+ return conf.getboolean("core", "pool_include_deferred")
+ return None
+
+ @property
+ def effective_include_deferred(self) -> bool:
Review Comment:
This is option 1 in my comment above, but I think option 3 is better and
less confusing for users
--
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]
