Skip to content

Commit 2235073

Browse files
committed
Add back logger until all functions are refactored
1 parent 5cea64d commit 2235073

File tree

2 files changed

+3
-15
lines changed

2 files changed

+3
-15
lines changed

functions-python/batch_process_dataset/src/main.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -146,9 +146,7 @@ def upload_dataset(self) -> DatasetFile or None:
146146
:return: the file hash and the hosted url as a tuple or None if no upload is required
147147
"""
148148
try:
149-
self.logger.info(
150-
"Accessing URL %s", self.producer_url
151-
)
149+
self.logger.info("Accessing URL %s", self.producer_url)
152150
temp_file_path = self.generate_temp_filename()
153151
file_sha256_hash, is_zip = self.download_content(temp_file_path)
154152
if not is_zip:

functions-python/helpers/logger.py

Lines changed: 2 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -35,27 +35,17 @@ def filter(self, record):
3535
record.msg = f"[{self.stable_id}] {record.msg}"
3636
return True
3737

38-
39-
_logger_initialized = False
40-
lock = threading.Lock()
41-
42-
4338
def init_logger():
4439
"""
4540
Initializes the logger
4641
"""
47-
with lock:
48-
global _logger_initialized
49-
if _logger_initialized:
50-
return
51-
logging.basicConfig(level=get_env_logging_level())
52-
_logger_initialized = True
42+
logging.basicConfig(level=get_env_logging_level())
5343

5444

5545
def get_logger(name: str, stable_id: str = None):
5646
logger = logging.getLogger(name)
5747
if stable_id and not any(
58-
isinstance(handler, StableIdFilter) for handler in logger.handlers
48+
isinstance(log_filter, StableIdFilter) for log_filter in logger.filters
5949
):
6050
logger.addFilter(StableIdFilter(stable_id))
6151
return logger

0 commit comments

Comments
 (0)