Add failure cases for test

Author: Hanzhang Zeng (Roger)

tests/unittests/eventhub_mock_functions/eventhub_cardinality_many/__init__.py

@@ -2,5 +2,6 @@
 import azure.functions as func
 
 
+# This is testing the function load feature for the multiple events annotation
 def main(events: List[func.EventHubEvent]) -> str:
-    return 'OK'
+    return 'OK_MANY'

tests/unittests/eventhub_mock_functions/eventhub_cardinality_many_bad_anno/__init__.py

@@ -0,0 +1,8 @@
+from typing import List
+import azure.functions as func
+
+
+# This is testing the function load feature for the multiple events annotation
+# The event shouldn't be List[str]
+def main(events: List[str]) -> str:
+    return 'BAD'

tests/unittests/eventhub_mock_functions/eventhub_cardinality_many_bad_anno/function.json

@@ -0,0 +1,21 @@
+{
+    "scriptFile": "__init__.py",
+
+    "bindings": [
+      {
+        "type": "eventHubTrigger",
+        "name": "events",
+        "direction": "in",
+        "eventHubName": "python-worker-iot-ci",
+        "connection": "AzureWebJobsEventHubConnectionString",
+        "cardinality": "many"
+      },
+      {
+        "type": "blob",
+        "direction": "out",
+        "name": "$return",
+        "connection": "AzureWebJobsStorage",
+        "path": "python-worker-tests/test-eventhub-iot-triggered.txt"
+      }
+    ]
+  }

tests/unittests/eventhub_mock_functions/eventhub_cardinality_one/__init__.py

@@ -1,5 +1,6 @@
 import azure.functions as func
 
 
+# This is testing the function load feature for the single event annotation
 def main(event: func.EventHubEvent) -> str:
-    return 'OK'
+    return 'OK_ONE'

tests/unittests/eventhub_mock_functions/eventhub_cardinality_one_bad_anno/__init__.py

@@ -0,0 +1,7 @@
+import azure.functions as func
+
+
+# This is testing the function load feature for the single event annotation
+# The event shouldn't be int
+def main(event: int) -> str:
+    return 'BAD'

tests/unittests/eventhub_mock_functions/eventhub_cardinality_one_bad_anno/function.json

@@ -0,0 +1,21 @@
+{
+    "scriptFile": "__init__.py",
+
+    "bindings": [
+      {
+        "type": "eventHubTrigger",
+        "name": "event",
+        "direction": "in",
+        "eventHubName": "python-worker-iot-ci",
+        "connection": "AzureWebJobsEventHubConnectionString",
+        "cardinality": "one"
+      },
+      {
+        "type": "blob",
+        "direction": "out",
+        "name": "$return",
+        "connection": "AzureWebJobsStorage",
+        "path": "python-worker-tests/test-eventhub-iot-triggered.txt"
+      }
+    ]
+  }

tests/unittests/test_mock_eventhub_functions.py

@@ -75,7 +75,19 @@ async def test_mock_eventhub_cardinality_one(self):
 
             self.assertEqual(r.response.result.status,
                              protos.StatusResult.Success)
-            self.assertEqual(r.response.return_value.string, 'OK')
+            self.assertEqual(r.response.return_value.string, 'OK_ONE')
+
+    async def test_mock_eventhub_cardinality_one_bad_annotation(self):
+        async with testutils.start_mockhost(
+                script_root=self.mock_funcs_dir) as host:
+
+            # This suppose to fail since the event should not be int
+            func_id, r = await host.load_function(
+                'eventhub_cardinality_one_bad_anno'
+            )
+            self.assertEqual(r.response.function_id, func_id)
+            self.assertEqual(r.response.result.status,
+                             protos.StatusResult.Failure)
 
     async def test_mock_eventhub_cardinality_many(self):
         async with testutils.start_mockhost(
@@ -103,4 +115,16 @@ async def test_mock_eventhub_cardinality_many(self):
 
             self.assertEqual(r.response.result.status,
                              protos.StatusResult.Success)
-            self.assertEqual(r.response.return_value.string, 'OK')
+            self.assertEqual(r.response.return_value.string, 'OK_MANY')
+
+    async def test_mock_eventhub_cardinality_many_bad_annotation(self):
+        async with testutils.start_mockhost(
+                script_root=self.mock_funcs_dir) as host:
+
+            # This suppose to fail since the event should not be List[str]
+            func_id, r = await host.load_function(
+                'eventhub_cardinality_many_bad_anno'
+            )
+            self.assertEqual(r.response.function_id, func_id)
+            self.assertEqual(r.response.result.status,
+                             protos.StatusResult.Failure)