in 3-ai-native-e2e-sample/backend/agents/trials/event_consumer/consumer.py [0:0]
def close(self) -> None:
"""Close the consumer client."""
if self.consumer:
logger.info("🛑 Closing trial event consumer")
self.consumer.close()