fix: make analyze_cluster function async

2025-10-06 15:05:30 -03:00
parent fe8d59659c
commit b204653882
1 changed files with 1 additions and 1 deletions
--- a/app/tasks/cluster_analysis.py
+++ b/app/tasks/cluster_analysis.py
@@ -12,7 +12,7 @@ import logging
 logger = logging.getLogger(__name__)

@celery_app.task(bind=True, name='app.tasks.cluster_analysis.analyze_cluster')
-def analyze_cluster(self, cluster_config=None):
+async def analyze_cluster(self, cluster_config=None):
    """
    Analyze cluster resources and generate recommendations.