def __init__(self, flush_interval: float, flush_count: int):
        """
        Initialize the MetricsFlusher.
        :param flush_interval: Interval in seconds between each flush.
        :param flush_count: Number of items to remove from the queue at each flush.
        """
        self._dd_api_key = yeti_config.get("datadog", "api_key")
        self._dd_app_key = yeti_config.get("datadog", "app_key")
        self._dd_env = yeti_config.get("datadog", "env", "dev")
        self._session = requests.Session()
        self._session.headers = {
            "DD-API-KEY": self._dd_api_key,
            "DD-APPLICATION-KEY": self._dd_app_key,
        }
        self._logger = logging.getLogger("FlushMetricsQueue")
        self._flush_interval = flush_interval
        self._flush_count = flush_count
        self._running = True

        super().__init__(daemon=True)

        Initialize the MetricsFlusher.
        :param flush_interval: Interval in seconds between each flush.
        :param flush_count: Number of items to remove from the queue at each flush.
        
plugins/events/public/datadog_metrics.py