gourisankar85 commited on
Commit
cfea646
·
verified ·
1 Parent(s): 8ca1ec6

Upload helper.py

Browse files
Files changed (1) hide show
  1. scripts/helper.py +23 -1
scripts/helper.py CHANGED
@@ -3,6 +3,9 @@ import os
3
  import time
4
  import logging
5
 
 
 
 
6
  # Helper function to ensure directory exists
7
  def ensure_directory_exists(filepath):
8
  """Ensure the directory for a given file path exists."""
@@ -44,4 +47,23 @@ def load_dataset(file_name):
44
  for line in f:
45
  dataset.append(json.loads(line.strip())) # Load each JSON object per line
46
  logging.info(f"Loaded {len(dataset)} entries from file {file_name}") # Check how many records were loaded
47
- return dataset
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
3
  import time
4
  import logging
5
 
6
+ # Create a list to store logs
7
+ logs = []
8
+
9
  # Helper function to ensure directory exists
10
  def ensure_directory_exists(filepath):
11
  """Ensure the directory for a given file path exists."""
 
47
  for line in f:
48
  dataset.append(json.loads(line.strip())) # Load each JSON object per line
49
  logging.info(f"Loaded {len(dataset)} entries from file {file_name}") # Check how many records were loaded
50
+ return dataset
51
+
52
+ def initialize_logging():
53
+ logger = logging.getLogger()
54
+ logger.setLevel(logging.INFO)
55
+
56
+ # Custom log handler to capture logs and add them to the logs list
57
+ class LogHandler(logging.Handler):
58
+ def emit(self, record):
59
+ log_entry = self.format(record)
60
+ logs.append(log_entry)
61
+
62
+ # Add custom log handler to the logger
63
+ log_handler = LogHandler()
64
+ log_handler.setFormatter(logging.Formatter('%(asctime)s - %(message)s'))
65
+ logger.addHandler(log_handler)
66
+
67
+ def get_logs():
68
+ """Retrieve logs for display."""
69
+ return "\n".join(logs[-50:])