Minor code smell refactoring, updating pipelines and description added. (#64)

Author: vrdmr

azure-pipelines.yml

@@ -1,38 +1,49 @@
 trigger:
-- master
-- dev
+  - master
+  - dev
+
+schedules:
+  - cron: "0 8 * * 1,3,5"
+    displayName: Monday, Wednesday and Friday - 1 AM (PDT) build
+    branches:
+      include:
+        - dev
+        - master
+      exclude:
+        - release/*
+        - releases/ancient/*
 
 jobs:
-- job: Tests
-  pool:
-    vmImage: 'ubuntu-16.04'
-  strategy:
-    matrix:
-      Python36:
-        pythonVersion: '3.6'
-      Python37:
-        pythonVersion: '3.7'
-      Python38:
-        pythonVersion: '3.8'
-    maxParallel: 3
-  steps:
-  - task: UsePythonVersion@0
-    inputs:
-      versionSpec: '$(pythonVersion)'
-      addToPath: true
-  - task: ShellScript@2
-    inputs:
-      disableAutoCwd: true
-      scriptPath: .ci/build.sh
-    displayName: 'Build'
-  - bash: |
-        chmod +x .ci/run_tests.sh
-        .ci/run_tests.sh
-    displayName: 'Run Tests'
-  - task: PublishCodeCoverageResults@1
-    inputs:
-      codeCoverageTool: cobertura
-      summaryFileLocation: coverage.xml
-  - bash: |
-        rm coverage.xml
-    displayName: 'Clearing coverage.xml file'
+  - job: Tests
+    pool:
+      vmImage: 'ubuntu-16.04'
+    strategy:
+      matrix:
+        Python36:
+          pythonVersion: '3.6'
+        Python37:
+          pythonVersion: '3.7'
+        Python38:
+          pythonVersion: '3.8'
+      maxParallel: 3
+    steps:
+      - task: UsePythonVersion@0
+        inputs:
+          versionSpec: '$(pythonVersion)'
+          addToPath: true
+      - task: ShellScript@2
+        inputs:
+          disableAutoCwd: true
+          scriptPath: .ci/build.sh
+        displayName: 'Build'
+      - bash: |
+          chmod +x .ci/run_tests.sh
+          .ci/run_tests.sh
+        displayName: 'Run Tests'
+      - task: PublishCodeCoverageResults@1
+        inputs:
+          codeCoverageTool: cobertura
+          summaryFileLocation: coverage.xml
+      - bash: |
+          rm coverage.xml
+        displayName: 'Clearing coverage.xml file'

azure/__init__.py

@@ -1,5 +1,7 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 from pkgutil import extend_path
 import typing
+
 __path__: typing.Iterable[str] = extend_path(__path__, __name__)

azure/functions/__init__.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 from ._abc import TimerRequest, InputStream, Context, Out  # NoQA
 from ._eventhub import EventHubEvent  # NoQA
 from ._eventgrid import EventGridEvent, EventGridOutputEvent  # NoQA
@@ -12,6 +13,7 @@
 from ._servicebus import ServiceBusMessage  # NoQA
 from ._durable_functions import OrchestrationContext  # NoQA
 from .meta import get_binding_registry  # NoQA
+
 # Import binding implementations to register them
 from . import blob  # NoQA
 from . import cosmosdb  # NoQA

azure/functions/_abc.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import abc
 import datetime
 import io

azure/functions/_cosmosdb.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import collections
 import json
 

azure/functions/_durable_functions.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 from typing import Union
 from . import _abc
 from importlib import import_module
@@ -35,12 +36,11 @@ def _serialize_custom_object(obj):
                         "function")
     # Encode to json using the object's `to_json`
     obj_type = type(obj)
-    dict_obj = {
+    return {
         "__class__": obj.__class__.__name__,
         "__module__": obj.__module__,
         "__data__": obj_type.to_json(obj)
     }
-    return dict_obj
 
 
 def _deserialize_custom_object(obj: dict) -> object:

azure/functions/_eventgrid.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import datetime
 import typing
 

azure/functions/_eventhub.py

@@ -1,13 +1,14 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import datetime
 import typing
 
-from azure.functions import _abc as funcabc
+from azure.functions import _abc as func_abc
 from azure.functions import meta
 
 
-class EventHubEvent(funcabc.EventHubEvent):
+class EventHubEvent(func_abc.EventHubEvent):
     """A concrete implementation of Event Hub message type."""
 
     def __init__(self, *,

azure/functions/_http.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import collections.abc
 import io
 import json

azure/functions/_http_wsgi.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 from typing import Callable, Dict, List, Optional, Any
 from io import BytesIO, StringIO
 from os import linesep

azure/functions/_kafka.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import abc
 import typing
 

azure/functions/_queue.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import datetime
 import json
 import typing

azure/functions/_thirdparty/typing_inspect.py

@@ -301,7 +301,7 @@ def get_args(tp, evaluate=None):
         get_args(Callable[[], T][int], evaluate=True) == ([], int,)
     """
     if NEW_TYPING:
-        if evaluate is not None and not evaluate:
+        if not (evaluate is None or evaluate):
             raise ValueError('evaluate can only be True in Python 3.7')
         if isinstance(tp, _GenericAlias):
             res = tp.__args__

azure/functions/_utils.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 from typing import List, Tuple, Optional
 from datetime import datetime
 

azure/functions/blob.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import io
 from typing import Optional, Union, Any
 
@@ -96,10 +97,7 @@ def decode(cls, data: meta.Datum, *, trigger_metadata) -> Any:
                 trigger_metadata, 'Properties', python_type=dict)
             if properties:
                 length = properties.get('Length')
-                if length:
-                    length = int(length)
-                else:
-                    length = None
+                length = int(length) if length else None
             else:
                 length = None
 

azure/functions/cosmosdb.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import collections.abc
 import json
 import typing
@@ -30,15 +31,12 @@ def decode(cls,
 
         data_type = data.type
 
-        if data_type == 'string':
+        if data_type in ['string', 'json']:
             body = data.value
 
         elif data_type == 'bytes':
             body = data.value.decode('utf-8')
 
-        elif data_type == 'json':
-            body = data.value
-
         else:
             raise NotImplementedError(
                 f'unsupported queue payload type: {data_type}')

azure/functions/durable_functions.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import typing
 import json
 
@@ -61,7 +62,7 @@ def decode(cls,
 
         # Durable functions extension always returns a string of json
         # See durable functions library's call_activity_task docs
-        if data_type == 'string' or data_type == 'json':
+        if data_type in ['string', 'json']:
             try:
                 callback = _durable_functions._deserialize_custom_object
                 result = json.loads(data.value, object_hook=callback)

azure/functions/eventgrid.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import collections
 import datetime
 import json

azure/functions/eventhub.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import json
 from typing import Dict, Any, List, Union, Optional, Mapping
 
@@ -33,12 +34,10 @@ def decode(
     ) -> Union[_eventhub.EventHubEvent, List[_eventhub.EventHubEvent]]:
         data_type = data.type
 
-        if (data_type == 'string' or data_type == 'bytes'
-                or data_type == 'json'):
+        if data_type in ['string', 'bytes', 'json']:
             return cls.decode_single_event(data, trigger_metadata)
 
-        elif (data_type == 'collection_bytes'
-                or data_type == 'collection_string'):
+        elif data_type in ['collection_bytes', 'collection_string']:
             return cls.decode_multiple_events(data, trigger_metadata)
 
         else:
@@ -48,15 +47,12 @@ def decode(
     @classmethod
     def decode_single_event(cls, data,
                             trigger_metadata) -> _eventhub.EventHubEvent:
-        if data.type == 'string':
+        if data.type in ['string', 'json']:
             body = data.value.encode('utf-8')
 
         elif data.type == 'bytes':
             body = data.value
 
-        elif data.type == 'json':
-            body = data.value.encode('utf-8')
-
         return _eventhub.EventHubEvent(body=body)
 
     @classmethod
@@ -70,8 +66,8 @@ def decode_multiple_events(
             parsed_data = data.value.string
 
         events = []
-        for i in range(len(parsed_data)):
-            event = _eventhub.EventHubEvent(body=parsed_data[i])
+        for parsed_datum in parsed_data:
+            event = _eventhub.EventHubEvent(body=parsed_datum)
             events.append(event)
 
         return events
@@ -119,15 +115,12 @@ def decode(
     def decode_single_event(
         cls, data, trigger_metadata: Mapping[str, meta.Datum]
     ) -> _eventhub.EventHubEvent:
-        if data.type == 'string':
+        if data.type in ['string', 'json']:
             body = data.value.encode('utf-8')
 
         elif data.type == 'bytes':
             body = data.value
 
-        elif data.type == 'json':
-            body = data.value.encode('utf-8')
-
         return _eventhub.EventHubEvent(
             body=body,
             trigger_metadata=trigger_metadata,

azure/functions/http.py

@@ -1,5 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import json
 import typing