Revert "test"

This reverts commit 4142767.

Author: hallvictoria

azure_functions_worker/bindings/meta.py

@@ -22,7 +22,7 @@
 def _check_http_input_type_annotation(bind_name: str, pytype: type) -> bool:
     if sys.version_info.minor >= BASE_EXT_SUPPORTED_PY_MINOR_VERSION and \
             is_envvar_true(PYTHON_ENABLE_INIT_INDEXING):
-        import azurefunctions.extension.base as ext_base
+        import azure.functions.extension.base as ext_base
         if ext_base.HttpV2FeatureChecker.http_v2_enabled():
             return ext_base.RequestTrackerMeta.check_type(pytype)
 
@@ -33,7 +33,7 @@ def _check_http_input_type_annotation(bind_name: str, pytype: type) -> bool:
 def _check_http_output_type_annotation(bind_name: str, pytype: type) -> bool:
     if sys.version_info.minor >= BASE_EXT_SUPPORTED_PY_MINOR_VERSION and \
             is_envvar_true(PYTHON_ENABLE_INIT_INDEXING):
-        import azurefunctions.extension.base as ext_base
+        import azure.functions.extension.base as ext_base
         if ext_base.HttpV2FeatureChecker.http_v2_enabled():
             return ext_base.ResponseTrackerMeta.check_type(pytype)
 

azure_functions_worker/dispatcher.py

@@ -316,7 +316,7 @@ async def _handle__worker_init_request(self, request):
 
             if sys.version_info.minor >= BASE_EXT_SUPPORTED_PY_MINOR_VERSION \
                     and self._has_http_func:
-                from azurefunctions.extension.base \
+                from azure.functions.extension.base \
                     import HttpV2FeatureChecker
 
                 if HttpV2FeatureChecker.http_v2_enabled():
@@ -482,7 +482,6 @@ async def _handle__function_load_request(self, request):
                         status=protos.StatusResult.Success)))
 
         except Exception as ex:
-            logger.warning("VICTORIA Error: {}", ex)
             return protos.StreamingMessage(
                 request_id=self.request_id,
                 function_load_response=protos.FunctionLoadResponse(
@@ -544,14 +543,14 @@ async def _handle__invocation_request(self, request):
                     BASE_EXT_SUPPORTED_PY_MINOR_VERSION \
                     and fi.trigger_metadata is not None \
                     and fi.trigger_metadata.get('type') == HTTP_TRIGGER:
-                from azurefunctions.extension.base import HttpV2FeatureChecker
+                from azure.functions.extension.base import HttpV2FeatureChecker
                 http_v2_enabled = HttpV2FeatureChecker.http_v2_enabled()
 
             if http_v2_enabled:
                 http_request = await http_coordinator.get_http_request_async(
                     invocation_id)
 
-                from azurefunctions.extension.base import RequestTrackerMeta
+                from azure.functions.extension.base import RequestTrackerMeta
                 route_params = {key: item.string for key, item
                                 in trigger_metadata.items() if key not in [
                                     'Headers', 'Query']}
@@ -704,7 +703,7 @@ async def _handle__function_environment_reload_request(self, request):
                 if sys.version_info.minor >= \
                         BASE_EXT_SUPPORTED_PY_MINOR_VERSION and \
                         self._has_http_func:
-                    from azurefunctions.extension.base \
+                    from azure.functions.extension.base \
                         import HttpV2FeatureChecker
 
                     if HttpV2FeatureChecker.http_v2_enabled():

azure_functions_worker/http_v2.py

@@ -165,7 +165,7 @@ def get_unused_tcp_port():
 
 
 def initialize_http_server():
-    from azurefunctions.extension.base \
+    from azure.functions.extension.base \
         import ModuleTrackerMeta, RequestTrackerMeta
 
     web_extension_mod_name = ModuleTrackerMeta.get_module()

azure_functions_worker/logging.py

@@ -13,7 +13,7 @@
 SDK_LOG_PREFIX = "azure.functions"
 SYSTEM_ERROR_LOG_PREFIX = "azure_functions_worker_errors"
 
-local_handler = logging.FileHandler("C:\\Users\\victoriahall\\Documents\\repos\\azure-functions-python-worker\\mylog.txt")
+
 logger: logging.Logger = logging.getLogger(SYSTEM_LOG_PREFIX)
 error_logger: logging.Logger = (
     logging.getLogger(SYSTEM_ERROR_LOG_PREFIX))
@@ -78,8 +78,6 @@ def setup(log_level, log_destination):
     error_logger.addHandler(error_handler)
     error_logger.setLevel(getattr(logging, log_level))
 
-    logger.addHandler(local_handler)
-
 
 def disable_console_logging() -> None:
     # We should only remove the sys.stdout stream, as error_logger is used for