refactor: rename 'openai_batch_' to 'batch_' in configuration and update related cache key references

Author: husainhackerrank-afk

src/configs/constant.py

@@ -40,7 +40,7 @@
     'metrix_bridges_' : 'metrix_bridges_',
     'rate_limit_' : 'rate_limit_',
     'files_' : 'files_',
-    'openai_batch_' : 'openai_batch_',
+    'batch_' : 'batch_',
     'avg_response_time_' : 'avg_response_time_',
     'gpt_memory_' : 'gpt_memory_',
     'timezone_and_org_' : 'timezone_and_org_',

src/services/commonServices/openAI/openai_batch.py

@@ -93,7 +93,7 @@ async def batch_execute(self):
             "batch_variables": batch_variables,
             "custom_id_mapping": {item["custom_id"]: idx for idx, item in enumerate(message_mappings)}
         }
-        cache_key = f"{redis_keys['openai_batch_']}{batch_file.id}"
+        cache_key = f"{redis_keys['batch_']}{batch_file.id}"
         await store_in_cache(cache_key, batch_json, ttl = 86400)
         return {
             "success": True,

src/services/utils/batch_script.py

@@ -20,7 +20,7 @@ async def repeat_function():
 async def check_batch_status():
     try:
         print("Batch Script running...")
-        batch_ids = await find_in_cache_with_prefix('openai_batch_')
+        batch_ids = await find_in_cache_with_prefix('batch_')
         if batch_ids is None:
             return
         for id in batch_ids:
@@ -96,7 +96,7 @@ async def check_batch_status():
                         has_success = any(item.get("status_code") is None or item.get("status_code", 200) < 400 for item in file_content)
 
                         await sendResponse(response_format, data=file_content, success=has_success)
-                    cache_key = f"{redis_keys['openai_batch_']}{batch_id}"
+                    cache_key = f"{redis_keys['batch_']}{batch_id}"
                     await delete_in_cache(cache_key)
             finally:
                 # Ensure http_client is properly closed