Update extensions to the latest version (#649)

Remove system log checking because not generated by user

Skip .sh shell when running on windows

Author: Hazhzeng

setup.py

@@ -18,8 +18,7 @@
 
 # TODO: change this to something more stable when available.
 WEBHOST_URL = ('https://ci.appveyor.com/api/buildjobs/19gqd7drpxhkedea'
-               '/artifacts'
-               '/Functions.Binaries.2.0.13036.no-runtime.zip')
+               '/artifacts/Functions.Binaries.2.0.13036.no-runtime.zip')
 
 # Extensions necessary for non-core bindings.
 AZURE_EXTENSIONS = """\
@@ -32,23 +31,23 @@
   <ItemGroup>
     <PackageReference
         Include="Microsoft.Azure.WebJobs.Script.ExtensionsMetadataGenerator"
-        Version="1.0.1"
+        Version="1.1.7"
     />
     <PackageReference
         Include="Microsoft.Azure.WebJobs.Extensions.CosmosDB"
-        Version="3.0.1"
+        Version="3.0.5"
     />
     <PackageReference
         Include="Microsoft.Azure.WebJobs.Extensions.EventHubs"
-        Version="3.0.0"
+        Version="3.0.6"
     />
     <PackageReference
         Include="Microsoft.Azure.WebJobs.Extensions.EventGrid"
-        Version="2.0.0"
+        Version="2.1.0"
     />
     <PackageReference
         Include="Microsoft.Azure.WebJobs.Extensions.Storage"
-        Version="3.0.0"
+        Version="3.0.10"
     />
     <PackageReference
         Include="Microsoft.Azure.WebJobs.ServiceBus"

tests/unittests/test_http_functions.py

@@ -90,26 +90,20 @@ def test_async_logging(self):
         self.assertEqual(r.text, 'OK-async')
 
     def check_log_async_logging(self, host_out: typing.List[str]):
+        # Host out only contains user logs
         self.assertIn('hello info', host_out)
         self.assertIn('and another error', host_out)
 
-        # We should see "Function is async"
-        is_async = any([ho.startswith("Function is async") for ho in host_out])
-        self.assertTrue(is_async)
-
     def test_sync_logging(self):
         # Test that logging doesn't *break* things.
         r = self.webhost.request('GET', 'sync_logging')
         self.assertEqual(r.status_code, 200)
         self.assertEqual(r.text, 'OK-sync')
 
     def check_log_sync_logging(self, host_out: typing.List[str]):
+        # Host out only contains user logs
         self.assertIn('a gracefully handled error', host_out)
 
-        # We should see a warning "Function is sync"
-        is_sync = any([ho.startswith("Function is sync") for ho in host_out])
-        self.assertTrue(is_sync)
-
     def test_return_context(self):
         r = self.webhost.request('GET', 'return_context')
         self.assertEqual(r.status_code, 200)

tests/unittests/test_loader.py

@@ -80,7 +80,11 @@ async def _runner():
 
             stdout, stderr = await proc.communicate()
 
-            self.assertEqual(stdout.strip().split(b'\n'), [b'True', b'True'])
+            # Trimming off carriage return charater when testing on Windows
+            stdout_lines = [
+                l.replace(b'\r', b'') for l in stdout.strip().split(b'\n')
+            ]
+            self.assertEqual(stdout_lines, [b'True', b'True'])
 
         finally:
             subprocess.run([

tests/unittests/test_rpc_messages.py

@@ -3,6 +3,7 @@
 import sys
 import typing
 import tempfile
+import unittest
 
 from azure_functions_worker import protos
 from azure_functions_worker import testutils
@@ -78,11 +79,15 @@ def _verify_sys_path_import(self, result, expected_output):
         finally:
             self._reset_environ()
 
+    @unittest.skipIf(sys.platform == 'win32',
+                     'Linux .sh script only works on Linux')
     def test_failed_sys_path_import(self):
         self._verify_sys_path_import(
             'fail',
             "No module named 'test_module'")
 
+    @unittest.skipIf(sys.platform == 'win32',
+                     'Linux .sh script only works on Linux')
     def test_successful_sys_path_import(self):
         self._verify_sys_path_import(
             'success',
@@ -105,11 +110,15 @@ def _verify_azure_namespace_import(self, result, expected_output):
         finally:
             self._reset_environ()
 
+    @unittest.skipIf(sys.platform == 'win32',
+                     'Linux .sh script only works on Linux')
     def test_failed_azure_namespace_import(self):
         self._verify_azure_namespace_import(
             'false',
             'module_b fails to import')
 
+    @unittest.skipIf(sys.platform == 'win32',
+                     'Linux .sh script only works on Linux')
     def test_successful_azure_namespace_import(self):
         self._verify_azure_namespace_import(
             'true',