Merge branch 'dev' into wangbill/native-type-hint

Author: hallvictoria

.ci/build.sh

@@ -0,0 +1,20 @@
+name: "PR Title Enforcer"
+
+on:
+  pull_request:
+    types:
+      - opened
+      - edited
+      - synchronize
+
+permissions:
+  pull-requests: read
+
+jobs:
+  main:
+    name: Validate PR title
+    runs-on: ubuntu-latest
+    steps:
+      - uses: amannn/action-semantic-pull-request@v5
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.ci/run_tests.sh

@@ -9,4 +9,5 @@
 # AZURE FUNCTIONS TEAM
 # For all file changes, github would automatically include the following people in the PRs.
 #
-* @vrdmr @gavin-aguiar @YunchuWang @pdthummar
+
+* @vrdmr @gavin-aguiar @YunchuWang @pdthummar @hallvictoria

.github/workflows/gh-tests-ci.yml

@@ -10,7 +10,7 @@
                          DecoratorApi, DataType, AuthLevel,
                          Cardinality, AccessRights, HttpMethod,
                          AsgiFunctionApp, WsgiFunctionApp,
-                         ExternalHttpFunctionApp)
+                         ExternalHttpFunctionApp, BlobSource)
 from ._durable_functions import OrchestrationContext, EntityContext
 from .decorators.function_app import (FunctionRegister, TriggerApi,
                                       BindingApi, SettingsApi)
@@ -94,7 +94,8 @@
     'AuthLevel',
     'Cardinality',
     'AccessRights',
-    'HttpMethod'
+    'HttpMethod',
+    'BlobSource'
 )
 
-__version__ = '1.18.0b4'
+__version__ = '1.21.0b2'

.github/workflows/pr_title_enforcer.yml

@@ -447,6 +447,11 @@ class ServiceBusMessage(abc.ABC):
     def get_body(self) -> typing.Union[str, bytes]:
         pass
 
+    @property
+    @abc.abstractmethod
+    def application_properties(self) -> typing.Dict[str, typing.Any]:
+        pass
+
     @property
     @abc.abstractmethod
     def content_type(self) -> typing.Optional[str]:
@@ -457,6 +462,16 @@ def content_type(self) -> typing.Optional[str]:
     def correlation_id(self) -> typing.Optional[str]:
         pass
 
+    @property
+    @abc.abstractmethod
+    def dead_letter_error_description(self) -> typing.Optional[str]:
+        pass
+
+    @property
+    @abc.abstractmethod
+    def dead_letter_reason(self) -> typing.Optional[str]:
+        pass
+
     @property
     @abc.abstractmethod
     def dead_letter_source(self) -> typing.Optional[str]:
@@ -467,6 +482,11 @@ def dead_letter_source(self) -> typing.Optional[str]:
     def delivery_count(self) -> typing.Optional[int]:
         pass
 
+    @property
+    @abc.abstractmethod
+    def enqueued_sequence_number(self) -> typing.Optional[int]:
+        pass
+
     @property
     @abc.abstractmethod
     def enqueued_time_utc(self) -> typing.Optional[datetime.datetime]:
@@ -488,6 +508,11 @@ def expiration_time(self) -> typing.Optional[datetime.datetime]:
     def label(self) -> typing.Optional[str]:
         pass
 
+    @property
+    @abc.abstractmethod
+    def locked_until(self) -> typing.Optional[datetime.datetime]:
+        pass
+
     @property
     @abc.abstractmethod
     def lock_token(self) -> typing.Optional[str]:
@@ -534,6 +559,16 @@ def sequence_number(self) -> typing.Optional[int]:
     def session_id(self) -> typing.Optional[str]:
         pass
 
+    @property
+    @abc.abstractmethod
+    def state(self) -> typing.Optional[int]:
+        pass
+
+    @property
+    @abc.abstractmethod
+    def subject(self) -> typing.Optional[str]:
+        pass
+
     @property
     @abc.abstractmethod
     def time_to_live(self) -> typing.Optional[datetime.timedelta]:
@@ -544,6 +579,11 @@ def time_to_live(self) -> typing.Optional[datetime.timedelta]:
     def to(self) -> typing.Optional[str]:
         pass
 
+    @property
+    @abc.abstractmethod
+    def transaction_partition_key(self) -> typing.Optional[str]:
+        pass
+
     @property
     @abc.abstractmethod
     def user_properties(self) -> typing.Dict[str, typing.Any]:

CODEOWNERS

@@ -5,6 +5,7 @@
 import logging
 import asyncio
 from asyncio import Event, Queue
+from urllib.parse import ParseResult, urlparse
 from warnings import warn
 from wsgiref.headers import Headers
 
@@ -22,6 +23,8 @@ def __init__(self, func_req: HttpRequest,
         self.asgi_version = ASGI_VERSION
         self.asgi_spec_version = ASGI_SPEC_VERSION
         self._headers = func_req.headers
+        url: ParseResult = urlparse(func_req.url)
+        self.asgi_url_scheme = url.scheme
         super().__init__(func_req, func_ctx)
 
     def _get_encoded_http_headers(self) -> List[Tuple[bytes, bytes]]:
@@ -49,7 +52,7 @@ def to_asgi_http_scope(self):
             "asgi.spec_version": self.asgi_spec_version,
             "http_version": "1.1",
             "method": self.request_method,
-            "scheme": "https",
+            "scheme": self.asgi_url_scheme,
             "path": self.path_info,
             "raw_path": _raw_path,
             "query_string": _query_string,

azure/functions/__init__.py

@@ -29,8 +29,11 @@ def __init__(self,
         # Implement interfaces for PEP 3333 environ
         self.request_method = getattr(func_req, 'method', None)
         self.script_name = ''
-        self.path_info = unquote_to_bytes(
-            getattr(url, 'path', None)).decode('latin-1')  # type: ignore
+        self.path_info = (
+            unquote_to_bytes(getattr(url, 'path', None))  # type: ignore
+            .decode('latin-1' if type(self) is WsgiRequest else 'utf-8')
+        )
+
         self.query_string = getattr(url, 'query', None)
         self.content_type = self._lowercased_headers.get('content-type')
         self.content_length = str(len(func_req_body))

azure/functions/_abc.py

@@ -33,6 +33,20 @@ def __init__(self, *,
         if body is not None:
             self.__set_body(body)
 
+    @property
+    def application_properties(self) -> Dict[str, Any]:
+        """Gets the application properties bag, which can be used for
+        custom message metadata.
+
+        Returns:
+        --------
+        Dict[str, Any]:
+            If user has set application properties for the message,
+            returns a dictionary.
+            If nothing is set, returns an empty dictionary.
+        """
+        return {}
+
     @property
     def content_type(self) -> Optional[str]:
         """Optionally describes the payload of the message,
@@ -59,6 +73,30 @@ def correlation_id(self) -> Optional[str]:
         """
         return self.__correlation_id
 
+    @property
+    def dead_letter_error_description(self) -> Optional[str]:
+        """Optionally describes the dead letter error description for the message.
+
+        Returns:
+        --------
+        Optional[str]
+            If dead letter error description is set, returns a string.
+            Otherwise, returns None.
+        """
+        return None
+
+    @property
+    def dead_letter_reason(self) -> Optional[str]:
+        """Optionally describes the dead letter reason description for the message.
+
+        Returns:
+        --------
+        Optional[str]
+            If dead letter reason description is set, returns a string.
+            Otherwise, returns None.
+        """
+        return None
+
     @property
     def dead_letter_source(self) -> Optional[str]:
         """Only set in messages that have been dead-lettered and subsequently
@@ -89,6 +127,21 @@ def delivery_count(self) -> Optional[int]:
         """
         return None
 
+    @property
+    def enqueued_sequence_number(self) -> Optional[int]:
+        """For messages that have been auto-forwarded, this property reflects
+        the sequence number that had first been assigned to the message at its
+        original point of submission. This property is read-only. Optionally
+        describes the enqueued sequence number of the message.
+
+        Returns:
+        --------
+        Optional[int]
+            If enqueued sequence number is set, returns an integer.
+            Otherwise, returns None.
+        """
+        return None
+
     @property
     def enqueued_time_utc(self) -> Optional[datetime.datetime]:
         """The UTC instant at which the message has been accepted and stored
@@ -138,6 +191,24 @@ def label(self) -> Optional[str]:
         """
         return None
 
+    @property
+    def locked_until(self) -> Optional[datetime.datetime]:
+        """For messages retrieved under a lock (peek-lock receive mode, not
+        pre-settled) this property reflects the UTC instant until which the
+        message is held locked in the queue/subscription. When the lock
+        expires, the DeliveryCount is incremented and the message is again
+        available for retrieval. This property is read-only.Optionally
+        describes the date and time in UTC until which the message will be
+        locked in the queue/subscription.
+
+        Returns:
+        --------
+        Optional[datetime.datetime]
+            If locked until is set, returns a datetime.
+            Otherwise, returns None.
+        """
+        return None
+
     @property
     def lock_token(self) -> Optional[str]:
         """	The lock token is a reference to the lock that is being held by
@@ -267,6 +338,37 @@ def session_id(self) -> Optional[str]:
         """
         return None
 
+    @property
+    def state(self) -> Optional[int]:
+        """The state of the message can be Active, Deferred, or Scheduled.
+        Deferred messages have Deferred state, scheduled messages have
+        Scheduled state, all other messages have Active state. States are
+        represented by corresponding integer values. Active = 0,
+        Deferred = 1, Scheduled = 2.
+
+        Returns:
+        --------
+        Optional[int]
+            If state is set, returns an integer.
+            Otherwise, returns None.
+        """
+        return None
+
+    @property
+    def subject(self) -> Optional[str]:
+        """This property enables the application to indicate the purpose of the
+        message to the receiver in a standardized fashion, similar to an email
+        subject line. The mapped AMQP property is "subject". Optionally
+        describes the application specific label.
+
+        Returns:
+        --------
+        Optional[str]
+            If subject is set, returns a string.
+            Otherwise, returns None.
+        """
+        return None
+
     @property
     def time_to_live(self) -> Optional[datetime.timedelta]:
         """	This value is the relative duration after which the message
@@ -300,6 +402,22 @@ def to(self) -> Optional[str]:
         """
         return None
 
+    @property
+    def transaction_partition_key(self) -> Optional[str]:
+        """If a message is sent via a transfer queue in the scope of a transaction,
+        this value selects the transfer queue partition: This is functionally
+        equivalent to PartitionKey and ensures that messages are kept together
+        and in order as they are transferred. Optionally describes the
+        partition key. Maximum length is 128 characters.
+
+        Returns:
+        --------
+        Optional[str]
+            If transaction partition key is set, returns a string.
+            Otherwise, returns None.
+        """
+        return None
+
     @property
     def user_properties(self) -> Dict[str, Any]:
         """Contains user defined message properties.