def __init__()

in 3-ai-native-e2e-sample/backend/agents/trials/event_consumer/consumer.py [0:0]

• 8 lines of code
• 1 McCabe index (conditional complexity)

    def __init__(self, coordinator: TrialAgentCoordinator):
        """
        Initialize the consumer with a coordinator.

        The coordinator processes the event with its team-led agent system,
        integrating telemetry and aggregated analysis.
        """
        self.coordinator = coordinator
        self.consumer = EventHubConsumerClient.from_connection_string(
            conn_str=EVENT_HUBS_CONFIG["connection_string"],
            consumer_group=EVENT_HUBS_CONFIG["consumer_group"],
            eventhub_name=EVENT_HUBS_CONFIG["eventhub_name"]
        )
        logger.info("✅ Trial events consumer initialized")