Spaces:
Sleeping
Sleeping
File size: 969 Bytes
c01955c | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 |
from exception import MyException
from src.Agents.utils.Abstract import Pipeline
from src.Agents.components.generate_interview_performance import InterviewPerformance
from src.Agents.entity.config_entity import InterviewPerformanceConfig
import logging
import sys
class InterviewPerformancePipeline(Pipeline):
def __init__(self,):
self.interview_performance=InterviewPerformance(
interview_performance_config=InterviewPerformanceConfig
)
async def initiate(self,thread_id:str):
try:
logging.info("Entered in the initiate PerformancePipeline method")
performance=await self.interview_performance.get_performance(thread_id=thread_id)
logging.info("performance generated")
logging.info("Exiting from PerformancePipeline method")
return performance
except Exception as e:
raise MyException(e,sys)
|