run black on search & ma (Azure#20213)

* run black on core, search & ma

* update

* update

Author: xiangyan99

sdk/metricsadvisor/azure-ai-metricsadvisor/azure/__init__.py

@@ -1 +1 @@
-__path__ = __import__('pkgutil').extend_path(__path__, __name__)  # type: ignore
+__path__ = __import__("pkgutil").extend_path(__path__, __name__)  # type: ignore

sdk/metricsadvisor/azure-ai-metricsadvisor/azure/ai/__init__.py

@@ -1 +1 @@
-__path__ = __import__('pkgutil').extend_path(__path__, __name__)  # type: ignore
+__path__ = __import__("pkgutil").extend_path(__path__, __name__)  # type: ignore

sdk/metricsadvisor/azure-ai-metricsadvisor/azure/ai/metricsadvisor/_helpers.py

@@ -6,10 +6,7 @@
 
 # pylint: disable=protected-access
 
-from typing import (
-    Union,
-    TYPE_CHECKING
-)
+from typing import Union, TYPE_CHECKING
 import datetime
 import six
 from msrest import Serializer
@@ -28,38 +25,56 @@
     DatasourceSqlConnectionString,
     DatasourceDataLakeGen2SharedKey,
     DatasourceServicePrincipal,
-    DatasourceServicePrincipalInKeyVault
+    DatasourceServicePrincipalInKeyVault,
 )
 from ._metrics_advisor_key_credential import MetricsAdvisorKeyCredential
 from ._metrics_advisor_key_credential_policy import MetricsAdvisorKeyCredentialPolicy
+
 if TYPE_CHECKING:
     from ._generated.models import MetricFeedback
 
 
 def construct_alert_config_dict(update_kwargs):
 
     if "metricAlertingConfigurations" in update_kwargs:
-        update_kwargs["metricAlertingConfigurations"] = [
-            config._to_generated() for config in
-            update_kwargs["metricAlertingConfigurations"]
-        ] if update_kwargs["metricAlertingConfigurations"] else None
+        update_kwargs["metricAlertingConfigurations"] = (
+            [
+                config._to_generated()
+                for config in update_kwargs["metricAlertingConfigurations"]
+            ]
+            if update_kwargs["metricAlertingConfigurations"]
+            else None
+        )
 
     return update_kwargs
 
 
 def construct_detection_config_dict(update_kwargs):
 
     if "wholeMetricConfiguration" in update_kwargs:
-        update_kwargs["wholeMetricConfiguration"] = update_kwargs["wholeMetricConfiguration"]._to_generated_patch() \
-            if update_kwargs["wholeMetricConfiguration"] else None
+        update_kwargs["wholeMetricConfiguration"] = (
+            update_kwargs["wholeMetricConfiguration"]._to_generated_patch()
+            if update_kwargs["wholeMetricConfiguration"]
+            else None
+        )
     if "dimensionGroupOverrideConfigurations" in update_kwargs:
-        update_kwargs["dimensionGroupOverrideConfigurations"] = [
-            group._to_generated() for group in update_kwargs["dimensionGroupOverrideConfigurations"]
-        ] if update_kwargs["dimensionGroupOverrideConfigurations"] else None
+        update_kwargs["dimensionGroupOverrideConfigurations"] = (
+            [
+                group._to_generated()
+                for group in update_kwargs["dimensionGroupOverrideConfigurations"]
+            ]
+            if update_kwargs["dimensionGroupOverrideConfigurations"]
+            else None
+        )
     if "seriesOverrideConfigurations" in update_kwargs:
-        update_kwargs["seriesOverrideConfigurations"] = [
-            series._to_generated() for series in update_kwargs["seriesOverrideConfigurations"]
-        ] if update_kwargs["seriesOverrideConfigurations"] else None
+        update_kwargs["seriesOverrideConfigurations"] = (
+            [
+                series._to_generated()
+                for series in update_kwargs["seriesOverrideConfigurations"]
+            ]
+            if update_kwargs["seriesOverrideConfigurations"]
+            else None
+        )
 
     return update_kwargs
 
@@ -71,9 +86,16 @@ def construct_hook_dict(update_kwargs, hook_type):
         update_kwargs["hookParameter"] = {}
         update_kwargs["hookParameter"]["toList"] = update_kwargs["toList"]
         update_kwargs.pop("toList")
-    elif hook_type.lower() == "web" \
-            and any(key in update_kwargs for key in
-                    ["endpoint", "username", "password", "certificateKey", "certificatePassword"]):
+    elif hook_type.lower() == "web" and any(
+        key in update_kwargs
+        for key in [
+            "endpoint",
+            "username",
+            "password",
+            "certificateKey",
+            "certificatePassword",
+        ]
+    ):
         update_kwargs["hookType"] = "Webhook"
         update_kwargs["hookParameter"] = {}
         if "endpoint" in update_kwargs:
@@ -83,38 +105,50 @@ def construct_hook_dict(update_kwargs, hook_type):
         if "password" in update_kwargs:
             update_kwargs["hookParameter"]["password"] = update_kwargs.pop("password")
         if "certificateKey" in update_kwargs:
-            update_kwargs["hookParameter"]["certificateKey"] = update_kwargs.pop("certificateKey")
+            update_kwargs["hookParameter"]["certificateKey"] = update_kwargs.pop(
+                "certificateKey"
+            )
         if "certificatePassword" in update_kwargs:
-            update_kwargs["hookParameter"]["certificatePassword"] = update_kwargs.pop("certificatePassword")
+            update_kwargs["hookParameter"]["certificatePassword"] = update_kwargs.pop(
+                "certificatePassword"
+            )
 
     return update_kwargs
 
 
 def construct_data_feed_dict(update_kwargs):
     if "dataStartFrom" in update_kwargs:
-        update_kwargs["dataStartFrom"] = Serializer.serialize_iso(update_kwargs["dataStartFrom"])
+        update_kwargs["dataStartFrom"] = Serializer.serialize_iso(
+            update_kwargs["dataStartFrom"]
+        )
 
     if "dataSourceParameter" in update_kwargs:
-        update_kwargs["authenticationType"] = update_kwargs["dataSourceParameter"].authentication_type
-        update_kwargs["credentialId"] = update_kwargs["dataSourceParameter"].credential_id
-        update_kwargs["dataSourceParameter"] = update_kwargs["dataSourceParameter"]._to_generated_patch()
+        update_kwargs["authenticationType"] = update_kwargs[
+            "dataSourceParameter"
+        ].authentication_type
+        update_kwargs["credentialId"] = update_kwargs[
+            "dataSourceParameter"
+        ].credential_id
+        update_kwargs["dataSourceParameter"] = update_kwargs[
+            "dataSourceParameter"
+        ]._to_generated_patch()
     return update_kwargs
 
 
 def convert_to_generated_data_feed_type(
-        generated_feed_type,
-        name,
-        source,
-        granularity,
-        schema,
-        ingestion_settings,
-        admins=None,
-        data_feed_description=None,
-        missing_data_point_fill_settings=None,
-        rollup_settings=None,
-        viewers=None,
-        access_mode=None,
-        action_link_template=None
+    generated_feed_type,
+    name,
+    source,
+    granularity,
+    schema,
+    ingestion_settings,
+    admins=None,
+    data_feed_description=None,
+    missing_data_point_fill_settings=None,
+    rollup_settings=None,
+    viewers=None,
+    access_mode=None,
+    action_link_template=None,
 ):
     """Convert input to data feed generated model type
 
@@ -178,7 +212,9 @@ def convert_to_generated_data_feed_type(
         granularity_name=granularity.granularity_type,
         granularity_amount=granularity.custom_granularity_value,
         metrics=[metric._to_generated() for metric in schema.metrics],
-        dimension=[dimension._to_generated() for dimension in schema.dimensions] if schema.dimensions else None,
+        dimension=[dimension._to_generated() for dimension in schema.dimensions]
+        if schema.dimensions
+        else None,
         timestamp_column=schema.timestamp_column,
         data_start_from=ingestion_settings.ingestion_begin_time,
         max_concurrency=ingestion_settings.data_source_request_concurrency,
@@ -187,22 +223,28 @@ def convert_to_generated_data_feed_type(
         stop_retry_after_in_seconds=ingestion_settings.stop_retry_after,
         data_feed_description=data_feed_description,
         need_rollup=DataFeedRollupType._to_generated(rollup_settings.rollup_type)
-        if rollup_settings else None,
+        if rollup_settings
+        else None,
         roll_up_method=rollup_settings.rollup_method if rollup_settings else None,
         roll_up_columns=rollup_settings.auto_rollup_group_by_column_names
-        if rollup_settings else None,
+        if rollup_settings
+        else None,
         all_up_identification=rollup_settings.rollup_identification_value
-        if rollup_settings else None,
+        if rollup_settings
+        else None,
         fill_missing_point_type=missing_data_point_fill_settings.fill_type
-        if missing_data_point_fill_settings else None,
+        if missing_data_point_fill_settings
+        else None,
         fill_missing_point_value=missing_data_point_fill_settings.custom_fill_value
-        if missing_data_point_fill_settings else None,
+        if missing_data_point_fill_settings
+        else None,
         viewers=viewers,
         view_mode=access_mode,
         admins=admins,
-        action_link_template=action_link_template
+        action_link_template=action_link_template,
     )
 
+
 def convert_to_sub_feedback(feedback):
     # type: (MetricFeedback) -> Union[AnomalyFeedback, ChangePointFeedback, CommentFeedback, PeriodFeedback]
     if feedback.feedback_type == "Anomaly":
@@ -215,6 +257,7 @@ def convert_to_sub_feedback(feedback):
         return PeriodFeedback._from_generated(feedback)  # type: ignore
     raise HttpResponseError("Invalid feedback type returned in the response.")
 
+
 def convert_datetime(date_time):
     # type: (Union[str, datetime.datetime]) -> datetime.datetime
     if isinstance(date_time, datetime.datetime):
@@ -229,6 +272,7 @@ def convert_datetime(date_time):
                 return datetime.datetime.strptime(date_time, "%Y-%m-%d %H:%M:%S")
     raise TypeError("Bad datetime type")
 
+
 def get_authentication_policy(credential):
     authentication_policy = None
     if credential is None:
@@ -243,6 +287,7 @@ def get_authentication_policy(credential):
 
     return authentication_policy
 
+
 def convert_to_datasource_credential(datasource_credential):
     if datasource_credential.data_source_credential_type == "AzureSQLConnectionString":
         return DatasourceSqlConnectionString._from_generated(datasource_credential)