initial commit

Author: hallvictoria

.artifactignore

@@ -10,6 +10,7 @@ exclude = .git, __pycache__, build, dist, .eggs, .github, .local, docs/,
           azure_functions_worker/_thirdparty/typing_inspect.py,
           tests/unittests/test_typing_inspect.py,
           tests/unittests/broken_functions/syntax_error/main.py,
+          tests/protos/,
           .env*, .vscode, venv*, *.venv*
 
 max-line-length = 88

.ci/e2e_integration_test/start-e2e.ps1

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

.devcontainer/Dockerfile

@@ -1,34 +1,35 @@
 # <img src="https://raw.githubusercontent.com/Azure/azure-functions-python-worker/dev/docs/Azure.Functions.svg" width = "30" alt="Functions Header Image - Lightning Logo"> Azure Functions Python Worker
 
-| Branch | Build Status                                                                                                                                                             | CodeCov                                                                                                                                                        | Test Status                                                                                                                                                             |
-|--------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
-| dev    | [![Build Status](https://img.shields.io/azure-devops/build/azfunc/public/658/dev)](https://azfunc.visualstudio.com/public/_build/latest?definitionId=658&branchName=dev) | [![codecov](https://codecov.io/gh/Azure/azure-functions-python-worker/branch/dev/graph/badge.svg)](https://codecov.io/gh/Azure/azure-functions-python-worker)  | [![Test Status](https://img.shields.io/azure-devops/build/azfunc/public/658/dev)](https://azfunc.visualstudio.com/public/_build/latest?definitionId=658&branchName=dev) |
+| Branch | Status                                                                                                                                                                                                                                       | CodeCov                                                                                                                                                        | Unittests                                                                                                                  | E2E tests                                                                                                                |
+|--------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------------------------------------------------------------------------------------------------|--------------------------------------------------------------------------------------------------------------------------|
+| main   | [![Build Status](https://azfunc.visualstudio.com/Azure%20Functions/_apis/build/status/Azure.azure-functions-python-worker?branchName=main)](https://azfunc.visualstudio.com/Azure%20Functions/_build/latest?definitionId=57&branchName=main) | [![codecov](https://codecov.io/gh/Azure/azure-functions-python-worker/branch/main/graph/badge.svg)](https://codecov.io/gh/Azure/azure-functions-python-worker) | ![CI Unit tests](https://github.com/Azure/azure-functions-python-worker/workflows/CI%20Unit%20tests/badge.svg?branch=main) | ![CI E2E tests](https://github.com/Azure/azure-functions-python-worker/workflows/CI%20E2E%20tests/badge.svg?branch=main) |
+| dev    | [![Build Status](https://azfunc.visualstudio.com/Azure%20Functions/_apis/build/status/Azure.azure-functions-python-worker?branchName=dev)](https://azfunc.visualstudio.com/Azure%20Functions/_build/latest?definitionId=57&branchName=dev)   | [![codecov](https://codecov.io/gh/Azure/azure-functions-python-worker/branch/dev/graph/badge.svg)](https://codecov.io/gh/Azure/azure-functions-python-worker)  | ![CI Unit tests](https://github.com/Azure/azure-functions-python-worker/workflows/CI%20Unit%20tests/badge.svg?branch=dev)  | ![CI E2E tests](https://github.com/Azure/azure-functions-python-worker/workflows/CI%20E2E%20tests/badge.svg?branch=dev)  |
 
-Python support for Azure Functions is based on Python 3.8, 3.9, 3.10, 3.11, and 3.12 serverless hosting on Linux and the Functions 4.0 runtime.
+Python support for Azure Functions is based on Python 3.6, 3.7, 3.8, 3.9, and 3.10 serverless hosting on Linux and the Functions 2.0, 3.0 and 4.0 runtime.
 
 Here is the current status of Python in Azure Functions:
 
 What are the supported Python versions?
 
-| Azure Functions Runtime          | Python 3.8 | Python 3.9 | Python 3.10 | Python 3.11 | Python 3.12 |
-|----------------------------------|------------|------------|-------------|-------------|-------------|
-| Azure Functions 3.0 (deprecated) | ✔          | ✔          | -           | -           | -           |
-| Azure Functions 4.0              | ✔          | ✔          | ✔           | ✔           | ✔           |     
+| Azure Functions Runtime          | Python 3.6 | Python 3.7 | Python 3.8 | Python 3.9 | Python 3.10 | Python 3.11 |
+|----------------------------------|------------|------------|------------|------------|-------------|-------------|
+| Azure Functions 2.0 (deprecated) | ✔          | ✔          | -          | -          | -           | -           |
+| Azure Functions 3.0 (deprecated)             | ✔          | ✔          | ✔          | ✔          | -           | -           |
+| Azure Functions 4.0              | -          | -          | ✔          | ✔          | ✔           | ✔           |     
 
 For information about Azure Functions Runtime, please refer to [Azure Functions runtime versions overview](https://docs.microsoft.com/en-us/azure/azure-functions/functions-versions) page.
 
 ### What's available?
 
-- Build, test, debug, and publish using Azure Functions Core Tools (CLI) or Visual Studio Code
-- Deploy Python Function project onto consumption, dedicated, elastic premium, or flex consumption plan.
-- Deploy Python Function project in a custom docker image onto dedicated or elastic premium plan.
-- Triggers / Bindings : Blob, Cosmos DB, Event Grid, Event Hub, HTTP, Kafka, MySQL, Queue, ServiceBus, SQL, Timer, and Warmup
+- Build, test, debug and publish using Azure Functions Core Tools (CLI) or Visual Studio Code
+- Deploy Python Function project onto consumption, dedicated, or elastic premium plan.
+- Deploy Python Function project in a custom docker image onto dedicated, or elastic premium plan.
+- Triggers / Bindings : HTTP, Blob, Queue, Timer, Cosmos DB, Event Grid, Event Hubs and Service Bus
 - Triggers / Bindings : Custom binding support
 
-### What's new?
+What's coming?
 
-- [SDK Type Bindings for Blob](https://techcommunity.microsoft.com/t5/azure-compute-blog/azure-functions-sdk-type-bindings-for-azure-blob-storage-with/ba-p/4146744)
-- [HTTP Streaming](https://techcommunity.microsoft.com/t5/azure-compute-blog/azure-functions-support-for-http-streams-in-python-is-now-in/ba-p/4146697)
+- [Durable Functions For Python](https://github.com/Azure/azure-functions-durable-python)
 
 ### Get Started
 
@@ -71,4 +72,4 @@ provided by the bot. You will only need to do this once across all repos using o
 
 This project has adopted the [Microsoft Open Source Code of Conduct](https://opensource.microsoft.com/codeofconduct/).
 For more information see the [Code of Conduct FAQ](https://opensource.microsoft.com/codeofconduct/faq/) or
-contact [[email protected]](mailto:[email protected]) with any additional questions or comments.
+contact [[email protected]](mailto:[email protected]) with any additional questions or comments.

.devcontainer/devcontainer.json

@@ -1,2 +1,6 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
+from .handle_event import worker_init_request, functions_metadata_request, function_environment_reload_request, invocation_request, functions_load_request
+
+__all__ = ('worker_init_request', 'functions_metadata_request', 'function_environment_reload_request', 'invocation_request', 'functions_load_request')

.flake8

@@ -1,13 +1,15 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
+
 import threading
+
 from typing import Type
 
-from . import RetryContext, TraceContext
+from .retrycontext import RetryContext
+from .tracecontext import TraceContext
 
 
 class Context:
-
     def __init__(self,
                  func_name: str,
                  func_dir: str,
@@ -45,3 +47,23 @@ def trace_context(self) -> TraceContext:
     @property
     def retry_context(self) -> RetryContext:
         return self.__retry_context
+
+
+def get_context(invoc_request, name: str,
+                 directory: str) -> Context:
+    """ For more information refer:
+    https://aka.ms/azfunc-invocation-context
+    """
+    trace_context = TraceContext(
+        invoc_request.trace_context.trace_parent,
+        invoc_request.trace_context.trace_state,
+        invoc_request.trace_context.attributes)
+
+    retry_context = RetryContext(
+        invoc_request.retry_context.retry_count,
+        invoc_request.retry_context.max_retry_count,
+        invoc_request.retry_context.exception)
+
+    return Context(
+        name, directory, invoc_request.invocation_id,
+        threading.local(), trace_context, retry_context)