diff --git a/crawler_management/crawler_management.py b/crawler_management/crawler_management.py index a94a232..72b6e72 100644 --- a/crawler_management/crawler_management.py +++ b/crawler_management/crawler_management.py @@ -9,7 +9,7 @@ class CrawlerManagement: self.redis_conn = RedisTaskManager(self.config_data) def get_task_item(self, task_data: Dict[str, Any]): - redis_key = f"{task_data["country"].lower()}_{task_data['app_name'].lower()}" + redis_key = f"{task_data["region"].lower()}_{task_data['app_name'].lower()}" result = self.redis_conn.get_random_task_and_delete(redis_key) if result: return result