Python worker version 1.0.4 (#621)

* Python worker version 1.0.4

* Update eventhub testcases

Author: Hazhzeng

setup.py

@@ -254,7 +254,7 @@ def run(self):
 
 setup(
     name='azure-functions-worker',
-    version='1.0.3',
+    version='1.0.4',
     description='Python Language Worker for Azure Functions Host',
     classifiers=[
         'License :: OSI Approved :: MIT License',
@@ -278,7 +278,7 @@ def run(self):
     ],
     extras_require={
         'dev': [
-            'azure-functions==1.0.8',
+            'azure-functions==1.1.0',
             'flake8~=3.7.9',
             'mypy',
             'pytest',

tests/unittests/test_mock_eventhub_functions.py

@@ -31,21 +31,22 @@ async def call_and_check():
                         ),
                     ],
                     metadata={
-                        'iothub-device-id': protos.TypedData(
-                            string='mock-iothub-device-id'
-                        ),
-                        'iothub-auth-data': protos.TypedData(
-                            string='mock-iothub-auth-data'
-                        )
+                        'SystemProperties': protos.TypedData(json=json.dumps({
+                            'iothub-device-id': 'mock-iothub-device-id',
+                            'iothub-auth-data': 'mock-iothub-auth-data',
+                            'EnqueuedTimeUtc': '2020-02-18T21:28:42.5888539Z'
+                        }))
                     }
                 )
 
                 self.assertEqual(r.response.result.status,
                                  protos.StatusResult.Success)
-                self.assertIn(
-                    'mock-iothub-device-id',
-                    r.response.return_value.string
-                )
+
+                res_json_string = r.response.return_value.string
+                self.assertIn('device-id', res_json_string)
+                self.assertIn('mock-iothub-device-id', res_json_string)
+                self.assertIn('auth-data', res_json_string)
+                self.assertIn('mock-iothub-auth-data', res_json_string)
 
             await call_and_check()
 
@@ -70,7 +71,13 @@ async def test_mock_eventhub_cardinality_one(self):
                         ),
                     ),
                 ],
-                metadata={}
+                metadata={
+                    'SystemProperties': protos.TypedData(json=json.dumps({
+                        'iothub-device-id': 'mock-iothub-device-id',
+                        'iothub-auth-data': 'mock-iothub-auth-data',
+                        'EnqueuedTimeUtc': '2020-02-18T21:28:42.5888539Z'
+                    }))
+                }
             )
 
             self.assertEqual(r.response.result.status,
@@ -104,13 +111,21 @@ async def test_mock_eventhub_cardinality_many(self):
                     protos.ParameterBinding(
                         name='events',
                         data=protos.TypedData(
-                            json=json.dumps({
+                            json=json.dumps([{
                                 'id': 'cardinality_many'
-                            })
+                            }])
                         ),
                     ),
                 ],
-                metadata={}
+                metadata={
+                    'SystemPropertiesArray': protos.TypedData(json=json.dumps([
+                        {
+                            'iothub-device-id': 'mock-iothub-device-id',
+                            'iothub-auth-data': 'mock-iothub-auth-data',
+                            'EnqueuedTimeUtc': '2020-02-18T21:28:42.5888539Z'
+                        }
+                    ]))
+                }
             )
 
             self.assertEqual(r.response.result.status,