This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch v3-3-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-3-test by this push:
new 039182cb6dd [v3-3-test] Remove unused ThreadSafeDict utility (#72918)
(#73078)
039182cb6dd is described below
commit 039182cb6dde08e8ab5b6a3667c5bf0300eab32f
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Sep 28 17:35:46 2026 +0200
[v3-3-test] Remove unused ThreadSafeDict utility (#72918) (#73078)
(cherry picked from commit 66bd6456eee60de75c0550af737042a45845cc10)
Co-authored-by: Aaron Chen <[email protected]>
---
airflow-core/src/airflow/utils/thread_safe_dict.py | 49 ----------------------
.../ci/prek/known_airflow_core_utils_modules.txt | 1 -
2 files changed, 50 deletions(-)
diff --git a/airflow-core/src/airflow/utils/thread_safe_dict.py
b/airflow-core/src/airflow/utils/thread_safe_dict.py
deleted file mode 100644
index ecd1aed202c..00000000000
--- a/airflow-core/src/airflow/utils/thread_safe_dict.py
+++ /dev/null
@@ -1,49 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-from __future__ import annotations
-
-import threading
-
-
-class ThreadSafeDict:
- """Dictionary that uses a lock during operations, to ensure thread
safety."""
-
- def __init__(self):
- self.sync_dict = {}
- self.thread_lock = threading.Lock()
-
- def set(self, key, value):
- with self.thread_lock:
- self.sync_dict[key] = value
-
- def get(self, key):
- with self.thread_lock:
- return self.sync_dict.get(key)
-
- def delete(self, key):
- with self.thread_lock:
- if key in self.sync_dict:
- del self.sync_dict[key]
-
- def clear(self):
- with self.thread_lock:
- self.sync_dict.clear()
-
- def get_all(self):
- with self.thread_lock:
- # Return a copy to avoid exposing the internal dictionary.
- return self.sync_dict.copy()
diff --git a/scripts/ci/prek/known_airflow_core_utils_modules.txt
b/scripts/ci/prek/known_airflow_core_utils_modules.txt
index bdd3a2aa51f..fd7b7ebe2aa 100644
--- a/scripts/ci/prek/known_airflow_core_utils_modules.txt
+++ b/scripts/ci/prek/known_airflow_core_utils_modules.txt
@@ -35,6 +35,5 @@ span_status
sqlalchemy
state
strings
-thread_safe_dict
types
yaml
