Run PEP8 on content (#57)

* Updated Python content to comply with PEP8 (via autopep8)

* Update autosuggest_samples.py

Author: sptramer

example.py

@@ -12,22 +12,27 @@
 
 import samples.tools
 
+
 def run_all_samples():
     for _, section_name_name, ispkg in pkgutil.walk_packages(samples.__path__):
         if not ispkg:
             continue
         section_package_name = "samples."+section_name_name
         section_package = importlib.import_module(section_package_name)
         for _, sample_name, _ in pkgutil.iter_modules(section_package.__path__):
-            sample_module = importlib.import_module(section_package_name+"."+sample_name)
-            subkey_env_name = getattr(sample_module, "SUBSCRIPTION_KEY_ENV_NAME", None)
+            sample_module = importlib.import_module(
+                section_package_name+"."+sample_name)
+            subkey_env_name = getattr(
+                sample_module, "SUBSCRIPTION_KEY_ENV_NAME", None)
             if not subkey_env_name:
                 continue
             print("Executing sample from ", sample_name)
             try:
-                samples.tools.execute_samples(sample_module.__dict__, subkey_env_name)
+                samples.tools.execute_samples(
+                    sample_module.__dict__, subkey_env_name)
             except samples.tools.SubscriptionKeyError as err:
                 print("{}\n".format(err))
 
+
 if __name__ == "__main__":
     run_all_samples()

samples/anomaly_detector_samples.py

@@ -7,9 +7,12 @@
 import os
 
 SUBSCRIPTION_KEY_ENV_NAME = "ANOMALYDETECTOR_SUBSCRIPTION_KEY"
-ANOMALYDETECTOR_LOCATION = os.environ.get("ANOMALYDETECTOR_LOCATION", "westcentralus")
+ANOMALYDETECTOR_LOCATION = os.environ.get(
+    "ANOMALYDETECTOR_LOCATION", "westcentralus")
+
+CSV_FOLDER = os.path.join(os.path.dirname(
+    os.path.realpath(__file__)), "csv_files")
 
-CSV_FOLDER = os.path.join(os.path.dirname(os.path.realpath(__file__)), "csv_files")
 
 def get_series_from_file(path):
     df = pd.read_csv(path, header=None, encoding="utf-8", parse_dates=[0])
@@ -18,16 +21,21 @@ def get_series_from_file(path):
         series.append(Point(timestamp=row[0], value=row[1]))
     return series
 
+
 def get_request():
-    series = get_series_from_file(os.path.join(CSV_FOLDER, "anomaly_detector_daily_series.csv"))
+    series = get_series_from_file(os.path.join(
+        CSV_FOLDER, "anomaly_detector_daily_series.csv"))
     return Request(series=series, granularity=Granularity.daily)
 
+
 def entire_detect(subscription_key):
     print("Sample of detecting anomalies in the entire series.")
 
-    endpoint = "https://{}.api.cognitive.microsoft.com".format(ANOMALYDETECTOR_LOCATION)
+    endpoint = "https://{}.api.cognitive.microsoft.com".format(
+        ANOMALYDETECTOR_LOCATION)
     try:
-        client = AnomalyDetectorClient(endpoint, CognitiveServicesCredentials(subscription_key))
+        client = AnomalyDetectorClient(
+            endpoint, CognitiveServicesCredentials(subscription_key))
         request = get_request()
         response = client.entire_detect(request)
         if True in response.is_anomaly:
@@ -44,12 +52,15 @@ def entire_detect(subscription_key):
         else:
             print(e)
 
+
 def last_detect(subscription_key):
     print("Sample of detecting whether the latest point in series is anomaly.")
 
-    endpoint = "https://{}.api.cognitive.microsoft.com".format(ANOMALYDETECTOR_LOCATION)
+    endpoint = "https://{}.api.cognitive.microsoft.com".format(
+        ANOMALYDETECTOR_LOCATION)
     try:
-        client = AnomalyDetectorClient(endpoint, CognitiveServicesCredentials(subscription_key))
+        client = AnomalyDetectorClient(
+            endpoint, CognitiveServicesCredentials(subscription_key))
         request = get_request()
         response = client.last_detect(request)
         if response.is_anomaly:
@@ -63,8 +74,10 @@ def last_detect(subscription_key):
         else:
             print(e)
 
+
 if __name__ == "__main__":
-    import sys, os.path
+    import sys
+    import os.path
     sys.path.append(os.path.abspath(os.path.join(__file__, "..", "..")))
     from tools import execute_samples
     execute_samples(globals(), SUBSCRIPTION_KEY_ENV_NAME)

samples/knowledge/qna_maker_samples.py

@@ -8,6 +8,7 @@
 SUBSCRIPTION_KEY_ENV_NAME = "QNA_SUBSCRIPTION_KEY"
 QNA_LOCATION = os.environ.get("QNA_LOCATION", "westus")
 
+
 def knowledge_based_crud_sample(subscription_key):
     """KnowledgeBasedCRUDSample.
 
@@ -23,17 +24,18 @@ def _create_sample_kb(client):
             questions=["How do I manage my knowledgebase?"],
             metadata=[MetadataDTO(name="Category", value="api")]
         )
-        urls = ["https://docs.microsoft.com/en-in/azure/cognitive-services/qnamaker/faqs"]
+        urls = [
+            "https://docs.microsoft.com/en-in/azure/cognitive-services/qnamaker/faqs"]
         create_kb_dto = CreateKbDTO(
             name="QnA Maker FAQ from quickstart",
             qna_list=[qna],
             urls=urls
         )
-        create_op = client.knowledgebase.create(create_kb_payload=create_kb_dto)
+        create_op = client.knowledgebase.create(
+            create_kb_payload=create_kb_dto)
         create_op = _monitor_operation(client=client, operation=create_op)
         return create_op.resource_location.replace("/knowledgebases/", "")
 
-
     def _monitor_operation(client, operation):
         """Helper function for knowledge_based_crud_sample.
 
@@ -42,17 +44,20 @@ def _monitor_operation(client, operation):
         """
         for i in range(20):
             if operation.operation_state in [OperationStateType.not_started, OperationStateType.running]:
-                print("Waiting for operation: {} to complete.".format(operation.operation_id))
+                print("Waiting for operation: {} to complete.".format(
+                    operation.operation_id))
                 time.sleep(5)
-                operation = client.operations.get_details(operation_id=operation.operation_id)
+                operation = client.operations.get_details(
+                    operation_id=operation.operation_id)
             else:
                 break
         if operation.operation_state != OperationStateType.succeeded:
-            raise Exception("Operation {} failed to complete.".format(operation.operation_id))
+            raise Exception("Operation {} failed to complete.".format(
+                operation.operation_id))
         return operation
 
-
-    client = QnAMakerClient(endpoint="https://{}.api.cognitive.microsoft.com".format(QNA_LOCATION), credentials=CognitiveServicesCredentials(subscription_key))
+    client = QnAMakerClient(endpoint="https://{}.api.cognitive.microsoft.com".format(
+        QNA_LOCATION), credentials=CognitiveServicesCredentials(subscription_key))
 
     # Create a KB
     print("Creating KB...")
@@ -68,7 +73,8 @@ def _monitor_operation(client, operation):
             ]
         )
     )
-    update_op = client.knowledgebase.update(kb_id=kb_id, update_kb=update_kb_operation_dto)
+    update_op = client.knowledgebase.update(
+        kb_id=kb_id, update_kb=update_kb_operation_dto)
     _monitor_operation(client=client, operation=update_op)
 
     # Publish the KB
@@ -88,7 +94,8 @@ def _monitor_operation(client, operation):
 
 
 if __name__ == "__main__":
-    import sys, os.path
+    import sys
+    import os.path
     sys.path.append(os.path.abspath(os.path.join(__file__, "..", "..")))
     from tools import execute_samples
-    execute_samples(globals(), SUBSCRIPTION_KEY_ENV_NAME)
+    execute_samples(globals(), SUBSCRIPTION_KEY_ENV_NAME)

samples/language/luis/luis_authoring_samples.py

@@ -9,6 +9,7 @@
 
 SUBSCRIPTION_KEY_ENV_NAME = "LUIS_SUBSCRIPTION_KEY"
 
+
 def booking_app(subscription_kuy):
     """Authoring.
 
@@ -24,7 +25,8 @@ def booking_app(subscription_kuy):
         default_app_name = "Contoso-{}".format(datetime.datetime.now())
         version_id = "0.1"
 
-        print("Creating App {}, version {}".format(default_app_name, version_id))
+        print("Creating App {}, version {}".format(
+            default_app_name, version_id))
 
         app_id = client.apps.add({
             'name': default_app_name,
@@ -111,17 +113,21 @@ def get_example_label(utterance, entity_name, value):
         utterances = [{
             'text': find_economy_to_madrid,
             'intent_name': intent_name,
-            'entity_labels':[
-                get_example_label(find_economy_to_madrid, "Flight", "economy to madrid"),
-                get_example_label(find_economy_to_madrid, "Destination", "Madrid"),
+            'entity_labels': [
+                get_example_label(find_economy_to_madrid,
+                                  "Flight", "economy to madrid"),
+                get_example_label(find_economy_to_madrid,
+                                  "Destination", "Madrid"),
                 get_example_label(find_economy_to_madrid, "Class", "economy"),
             ]
         }, {
             'text': find_first_to_london,
             'intent_name': intent_name,
-            'entity_labels':[
-                get_example_label(find_first_to_london, "Flight", "London in first class"),
-                get_example_label(find_first_to_london, "Destination", "London"),
+            'entity_labels': [
+                get_example_label(find_first_to_london,
+                                  "Flight", "London in first class"),
+                get_example_label(find_first_to_london,
+                                  "Destination", "London"),
                 get_example_label(find_first_to_london, "Class", "first"),
             ]
         }]
@@ -143,7 +149,8 @@ def get_example_label(utterance, entity_name, value):
         while not is_trained:
             time.sleep(1)
             status = client.train.get_status(app_id, version_id)
-            is_trained = all(m.details.status in trained_status for m in status)
+            is_trained = all(
+                m.details.status in trained_status for m in status)
 
         print("Your app is trained. You can now go to the LUIS portal and test it!")
 
@@ -158,12 +165,14 @@ def get_example_label(utterance, entity_name, value):
                 'region': 'westus'
             }
         )
-        endpoint = publish_result.endpoint_url + "?subscription-key=" + subscription_key + "&q="
+        endpoint = publish_result.endpoint_url + \
+            "?subscription-key=" + subscription_key + "&q="
         print("Your app is published. You can now go to test it on\n{}".format(endpoint))
 
     except Exception as err:
         print("Encountered exception. {}".format(err))
 
+
 def management(subscription_key):
     """Managing
 
@@ -179,7 +188,8 @@ def management(subscription_key):
         default_app_name = "Contoso-{}".format(datetime.datetime.now())
         version_id = "0.1"
 
-        print("Creating App {}, version {}".format(default_app_name, version_id))
+        print("Creating App {}, version {}".format(
+            default_app_name, version_id))
 
         app_id = client.apps.add({
             'name': default_app_name,
@@ -224,17 +234,20 @@ def management(subscription_key):
         # Listing versions
         print("\nList all versions in this app")
         for version in client.versions.list(app_id):
-            print("\t->Version: '{}', training status: {}".format(version.version, version.training_status))
+            print("\t->Version: '{}', training status: {}".format(version.version,
+                                                                  version.training_status))
 
         # Print app details
         print("\nPrint app '{}' details".format(default_app_name))
         details = client.apps.get(app_id)
-        pprint(details.as_dict())  # as_dict "dictify" the object, by default it's attribute based. e.g. details.name
+        # as_dict "dictify" the object, by default it's attribute based. e.g. details.name
+        pprint(details.as_dict())
 
         # Print version details
         print("\nPrint version '{}' details".format(version_id))
         details = client.versions.get(app_id, version_id)
-        pprint(details.as_dict())  # as_dict "dictify" the object, by default it's attribute based. e.g. details.name
+        # as_dict "dictify" the object, by default it's attribute based. e.g. details.name
+        pprint(details.as_dict())
 
         # Delete an app
         print("\nDelete app '{}'".format(default_app_name))
@@ -244,8 +257,10 @@ def management(subscription_key):
     except Exception as err:
         print("Encountered exception. {}".format(err))
 
+
 if __name__ == "__main__":
-    import sys, os.path
+    import sys
+    import os.path
     sys.path.append(os.path.abspath(os.path.join(__file__, "..", "..")))
     from tools import execute_samples
     execute_samples(globals(), SUBSCRIPTION_KEY_ENV_NAME)

samples/language/luis/luis_runtime_samples.py

@@ -10,6 +10,7 @@
 
 CWD = os.path.dirname(__file__)
 
+
 def runtime(subscription_key):
     """Resolve.
 
@@ -47,7 +48,8 @@ def runtime(subscription_key):
 
 
 if __name__ == "__main__":
-    import sys, os.path
+    import sys
+    import os.path
     sys.path.append(os.path.abspath(os.path.join(__file__, "..", "..")))
     from tools import execute_samples
     execute_samples(globals(), SUBSCRIPTION_KEY_ENV_NAME)

samples/language/spellcheck_samples.py

@@ -3,6 +3,7 @@
 
 SUBSCRIPTION_KEY_ENV_NAME = "SPELLCHECK_SUBSCRIPTION_KEY"
 
+
 def spellcheck(subscription_key):
     """SpellCheck.
 
@@ -17,15 +18,21 @@ def spellcheck(subscription_key):
         if result.flagged_tokens:
             first_spellcheck_result = result.flagged_tokens[0]
 
-            print("SpellCheck result count: {}".format(len(result.flagged_tokens)))
-            print("First SpellCheck token: {}".format(first_spellcheck_result.token))
-            print("First SpellCheck type: {}".format(first_spellcheck_result.type))
-            print("First SpellCheck suggestion count: {}".format(len(first_spellcheck_result.suggestions)))
+            print("SpellCheck result count: {}".format(
+                len(result.flagged_tokens)))
+            print("First SpellCheck token: {}".format(
+                first_spellcheck_result.token))
+            print("First SpellCheck type: {}".format(
+                first_spellcheck_result.type))
+            print("First SpellCheck suggestion count: {}".format(
+                len(first_spellcheck_result.suggestions)))
 
             if first_spellcheck_result.suggestions:
                 first_suggestion = first_spellcheck_result.suggestions[0]
-                print("First SpellCheck suggestion score: {}".format(first_suggestion.score))
-                print("First SpellCheck suggestion: {}".format(first_suggestion.suggestion))
+                print("First SpellCheck suggestion score: {}".format(
+                    first_suggestion.score))
+                print("First SpellCheck suggestion: {}".format(
+                    first_suggestion.suggestion))
             else:
                 print("Couldn't get any Spell check results!")
 
@@ -37,7 +44,8 @@ def spellcheck(subscription_key):
 
 
 if __name__ == "__main__":
-    import sys, os.path
-    sys.path.append(os.path.abspath(os.path.join(__file__, "..", "..")))    
+    import sys
+    import os.path
+    sys.path.append(os.path.abspath(os.path.join(__file__, "..", "..")))
     from tools import execute_samples
     execute_samples(globals(), SUBSCRIPTION_KEY_ENV_NAME)