This is an automated email from the ASF dual-hosted git repository.
ferruzzi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 0a816c6f0b Correct scheduled slots documentation and missing open
telemetry span (#41899)
0a816c6f0b is described below
commit 0a816c6f0b500e1b0515452e38e3446412f3e8e3
Author: Matt Burke <84401060+mattogbu...@users.noreply.github.com>
AuthorDate: Tue Sep 3 20:39:11 2024 +0100
Correct scheduled slots documentation and missing open telemetry span
(#41899)
* Correct documentation for pool.scheduled_slots metrics
* Add missing pool.scheduled_slots telemetry span
---
airflow/jobs/scheduler_job_runner.py | 1 +
.../administration-and-deployment/logging-monitoring/metrics.rst | 4 ++--
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/airflow/jobs/scheduler_job_runner.py
b/airflow/jobs/scheduler_job_runner.py
index 9b817ecc25..feb047ec5d 100644
--- a/airflow/jobs/scheduler_job_runner.py
+++ b/airflow/jobs/scheduler_job_runner.py
@@ -1844,6 +1844,7 @@ class SchedulerJobRunner(BaseJobRunner, LoggingMixin):
span.set_attribute(f"pool.queued_slots.{pool_name}",
slot_stats["queued"])
span.set_attribute(f"pool.running_slots.{pool_name}",
slot_stats["running"])
span.set_attribute(f"pool.deferred_slots.{pool_name}",
slot_stats["deferred"])
+ span.set_attribute(f"pool.scheduled_slots.{pool_name}",
slot_stats["scheduled"])
@provide_session
def adopt_or_reset_orphaned_tasks(self, session: Session = NEW_SESSION) ->
int:
diff --git
a/docs/apache-airflow/administration-and-deployment/logging-monitoring/metrics.rst
b/docs/apache-airflow/administration-and-deployment/logging-monitoring/metrics.rst
index 82597712a8..f3e69a9541 100644
---
a/docs/apache-airflow/administration-and-deployment/logging-monitoring/metrics.rst
+++
b/docs/apache-airflow/administration-and-deployment/logging-monitoring/metrics.rst
@@ -242,8 +242,8 @@ Name
Description
``pool.running_slots`` Number of running slots
in the pool. Metric with pool_name tagging.
``pool.deferred_slots.<pool_name>`` Number of deferred slots
in the pool
``pool.deferred_slots`` Number of deferred slots
in the pool. Metric with pool_name tagging.
-``pool.scheduled_tasks.<pool_name>`` Number of scheduled tasks
in the pool
-``pool.scheduled_tasks`` Number of scheduled tasks
in the pool. Metric with pool_name tagging.
+``pool.scheduled_slots.<pool_name>`` Number of scheduled slots
in the pool
+``pool.scheduled_slots`` Number of scheduled slots
in the pool. Metric with pool_name tagging.
``pool.starving_tasks.<pool_name>`` Number of starving tasks
in the pool
``pool.starving_tasks`` Number of starving tasks
in the pool. Metric with pool_name tagging.
``task.cpu_usage_percent.<dag_id>.<task_id>`` Percentage of CPU used by
a task
