We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4029da4 commit 5b2d41bCopy full SHA for 5b2d41b
1 file changed
airflow-core/src/airflow/api_fastapi/common/dagbag.py
@@ -47,12 +47,16 @@ def create_dag_bag() -> DBDagBag:
47
48
# Use unbounded dict (no eviction) if cache_size is 0
49
if cache_size <= 0:
50
- return DBDagBag(cache_size=0)
+ return DBDagBag(cache_size=0, stats_prefix="api_server.dag_bag")
51
52
# Disable TTL if cache_ttl is 0
53
cache_ttl: int | None = cache_ttl_config if cache_ttl_config > 0 else None
54
55
- return DBDagBag(cache_size=cache_size, cache_ttl=cache_ttl)
+ return DBDagBag(
56
+ cache_size=cache_size,
57
+ cache_ttl=cache_ttl,
58
+ stats_prefix="api_server.dag_bag",
59
+ )
60
61
62
def dag_bag_from_app(request: Request) -> DBDagBag:
0 commit comments