This is an automated email from the ASF dual-hosted git repository.
ash 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 4550cd2bb47 Skip more span-related DB queries in the scheduler when
tracing is disabled (#54591)
4550cd2bb47 is described below
commit 4550cd2bb47ac3b27807161b5568751d6d9fbe29
Author: Shlomit-B <[email protected]>
AuthorDate: Mon Aug 18 20:09:40 2025 +0300
Skip more span-related DB queries in the scheduler when tracing is disabled
(#54591)
---
airflow-core/src/airflow/jobs/scheduler_job_runner.py | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/airflow-core/src/airflow/jobs/scheduler_job_runner.py
b/airflow-core/src/airflow/jobs/scheduler_job_runner.py
index 6e5011e8685..fb6af1476c4 100644
--- a/airflow-core/src/airflow/jobs/scheduler_job_runner.py
+++ b/airflow-core/src/airflow/jobs/scheduler_job_runner.py
@@ -236,7 +236,8 @@ class SchedulerJobRunner(BaseJobRunner, LoggingMixin):
def _exit_gracefully(self, signum: int, frame: FrameType | None) -> None:
"""Clean up processor_agent to avoid leaving orphan processes."""
- self._end_active_spans()
+ if self._is_tracing_enabled():
+ self._end_active_spans()
if not _is_parent_process():
# Only the parent process should perform the cleanup.
@@ -1883,7 +1884,8 @@ class SchedulerJobRunner(BaseJobRunner, LoggingMixin):
return callback
if (
- dag_run.scheduled_by_job_id is not None
+ self._is_tracing_enabled()
+ and dag_run.scheduled_by_job_id is not None
and dag_run.scheduled_by_job_id != self.job.id
and self.active_spans.get("dr:" + str(dag_run.id)) is None
):
