Added e2e tests

Author: gavin-aguiar

azure_functions_worker/dispatcher.py

@@ -327,7 +327,8 @@ def get_function_metadata(self, directory, caller_info):
             default_value=f'{PYTHON_SCRIPT_FILE_NAME_DEFAULT}')
 
         logger.info(
-            'Received WorkerMetadataRequest from %s, request ID %s, script_file_name: %s',
+            'Received WorkerMetadataRequest from %s, request ID %s, '
+            'script_file_name: %s',
             caller_info, self.request_id, script_file_name)
 
         try:
@@ -389,7 +390,7 @@ async def _handle__function_load_request(self, request):
                     # function and update the workers registry
 
                     self.get_function_metadata(directory,
-                                               caller_info=sys._getframe().f_code.co_name)
+                                               sys._getframe().f_code.co_name)
                 else:
                     # legacy function
                     programming_model = "V1"

tests/endtoend/test_http_functions.py

@@ -205,7 +205,7 @@ def get_script_dir(cls):
                                             'common_libs_functions_stein'
 
 
-class TestHttpFunctionsWithInitIndexing(testutils.WebHostTestCase):
+class TestHttpFunctionsWithInitIndexing(TestHttpFunctions):
 
     @classmethod
     def setUpClass(cls):
@@ -218,22 +218,19 @@ def tearDownClass(cls):
         os.environ.pop('INIT_INDEXING')
         super().tearDownClass()
 
+
+class TestHttpFunctionsV2WithInitIndexing(TestHttpFunctionsStein):
+
     @classmethod
-    def get_script_dir(cls):
-        return testutils.E2E_TESTS_FOLDER / 'http_functions'
+    def setUpClass(cls):
+        os.environ["INIT_INDEXING"] = "1"
+        super().setUpClass()
 
-    def test_default_http_template_should_accept_body(self):
-        """Test if the azure.functions SDK is able to deserialize http body
-        and pass it to default template
-        """
-        r = self.webhost.request('POST', 'default_template',
-                                 data='{ "name": "body" }'.encode('utf-8'),
-                                 timeout=REQUEST_TIMEOUT_SEC)
-        self.assertTrue(r.ok)
-        self.assertEqual(
-            r.content,
-            b'Hello, body. This HTTP triggered function executed successfully.'
-        )
+    @classmethod
+    def tearDownClass(cls):
+        # Remove the PYTHON_SCRIPT_FILE_NAME environment variable
+        os.environ.pop('INIT_INDEXING')
+        super().tearDownClass()
 
 
 class TestUserThreadLoggingHttpFunctions(testutils.WebHostTestCase):

tests/endtoend/test_warmup_functions.py

@@ -2,10 +2,16 @@
 # Licensed under the MIT License.
 
 import typing
+from unittest import skipIf
 
+from azure_functions_worker.utils.common import is_envvar_true
 from tests.utils import testutils
+from tests.utils.constants import DEDICATED_DOCKER_TEST, CONSUMPTION_DOCKER_TEST
 
 
+@skipIf(is_envvar_true(DEDICATED_DOCKER_TEST)
+        or is_envvar_true(CONSUMPTION_DOCKER_TEST),
+        "Docker tests cannot call admin functions")
 class TestWarmupFunctions(testutils.WebHostTestCase):
     """Test the Warmup Trigger in the local webhost.
 
@@ -29,6 +35,9 @@ def check_log_warmup(self, host_out: typing.List[str]):
         self.assertEqual(host_out.count("Function App instance is warm"), 1)
 
 
+@skipIf(is_envvar_true(DEDICATED_DOCKER_TEST)
+        or is_envvar_true(CONSUMPTION_DOCKER_TEST),
+        "Docker tests cannot call admin functions")
 class TestWarmupFunctionsStein(TestWarmupFunctions):
 
     @classmethod