Remove steps already handled in driver base

microsoft · Jan 8, 2025 · ba52fca · ba52fca
1 parent c90799f
commit ba52fca
Showing 1 changed file with 2 additions and 10 deletions.
diff --git a/msticpy/data/drivers/azure_kusto_driver.py b/msticpy/data/drivers/azure_kusto_driver.py
@@ -184,10 +184,9 @@ def __init__(
             (can be overridden in connect method)
 
         """
-        super().__init__(**kwargs)
+        super().__init__(data_environment=data_environment, max_threads=max_threads)
         if debug:
             logger.setLevel(logging.DEBUG)
-        self.environment: DataEnvironment = data_environment
         self._strict_query_match: bool = strict_query_match
         self._kusto_settings: dict[str, dict[str, KustoConfig]] = _get_kusto_settings()
         self._default_database: str | None = None
@@ -196,21 +195,14 @@ def __init__(
         self.client: KustoClient | None = None
         self._az_auth_types: list[str] | None = None
         self._az_tenant_id: str | None = None
-        self._def_timeout: int = min(
-            timeout,
-            _MAX_TIMEOUT,
-        )
+        self._def_timeout: int = min(timeout, _MAX_TIMEOUT)
         self._def_proxies: dict[str, str] | None = proxies or get_http_proxies()
 
         self.add_query_filter("data_environments", "Kusto")
         self.set_driver_property(DriverProps.PUBLIC_ATTRS, self._set_public_attribs())
         self.set_driver_property(DriverProps.FILTER_ON_CONNECT, value=True)
         self.set_driver_property(DriverProps.EFFECTIVE_ENV, DataEnvironment.Kusto.name)
         self.set_driver_property(DriverProps.SUPPORTS_THREADING, value=True)
-        self.set_driver_property(
-            DriverProps.MAX_PARALLEL,
-            value=max_threads,
-        )
         self._loaded = True
 
     def _set_public_attribs(self: Self) -> dict[str, Any]: