support for returning list

Author: hallvictoria

azure_functions_worker/bindings/datumdef.py

@@ -199,9 +199,14 @@ def datum_as_proto(datum: Datum) -> protos.TypedData:
             enable_content_negotiation=False,
             body=datum_as_proto(datum.value['body']),
         ))
+    elif datum.type is None:
+        return None
     elif datum.type == 'dict':
         # TypedData doesn't support dict, so we return it as json
         return protos.TypedData(json=json.dumps(datum.value))
+    elif datum.type == 'list':
+        # TypedData doesn't support list, so we return it as json
+        return protos.TypedData(json=json.dumps(datum.value))
     elif datum.type == 'http_response':
         return protos.TypedData(http=protos.RpcHttp(
             status_code=str(datum.value.status_code),
@@ -211,10 +216,9 @@ def datum_as_proto(datum: Datum) -> protos.TypedData:
             },
             cookies=parse_to_rpc_http_cookie_list(None),
             enable_content_negotiation=False,
-            body=datum_as_proto(Datum(type="string", value=datum.value.get_body())),
+            body=datum_as_proto(Datum(type="string",
+                                      value=datum.value.get_body())),
         ))
-    elif datum.type is None:
-        return None
     else:
         raise NotImplementedError(
             'unexpected Datum type: {!r}'.format(datum.type)

azure_functions_worker/bindings/generic.py

@@ -32,6 +32,8 @@ def encode(cls, obj: Any, *,
             return datumdef.Datum(type=None, value=obj)
         elif isinstance(obj, dict):
             return datumdef.Datum(type='dict', value=obj)
+        elif isinstance(obj, list):
+            return datumdef.Datum(type='list', value=obj)
         else:
             # This isn't a common case so we do it last
             from azure.functions import HttpResponse

tests/endtoend/generic_functions/generic_functions_stein/function_app.py

@@ -86,3 +86,17 @@ def return_bytes(mytimer: func.TimerRequest, testEntity):
 def return_dict(mytimer: func.TimerRequest, testEntity):
     logging.info("Return dict")
     return {"hello": "world"}
+
+
+@app.function_name(name="return_list")
+@app.schedule(schedule="*/1 * * * * *", arg_name="mytimer",
+              run_on_startup=False,
+              use_monitor=False)
+@app.generic_input_binding(
+    arg_name="testEntity",
+    type="table",
+    connection="AzureWebJobsStorage",
+    table_name="EventHubBatchTest")
+def return_list(mytimer: func.TimerRequest, testEntity):
+    logging.info("Return list")
+    return [1, 2, 3]

tests/endtoend/generic_functions/return_list/function.json

@@ -0,0 +1,21 @@
+{
+  "scriptFile": "main.py",
+  "bindings": [
+    {
+      "name": "mytimer",
+      "type": "timerTrigger",
+      "direction": "in",
+      "schedule": "*/1 * * * * *",
+      "runOnStartup": false
+    },
+    {
+      "direction": "in",
+      "type": "table",
+      "name": "testEntity",
+      "partitionKey": "test",
+      "rowKey": "WillBePopulatedWithGuid",
+      "tableName": "BindingTestTable",
+      "connection": "AzureWebJobsStorage"
+    }
+  ]
+}

tests/endtoend/generic_functions/return_list/main.py

@@ -0,0 +1,11 @@
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License.
+
+import logging
+
+import azure.functions as func
+
+
+def main(mytimer: func.TimerRequest, testEntity):
+    logging.info("Return list")
+    return [1, 2, 3]

tests/endtoend/test_generic_functions.py

@@ -59,6 +59,7 @@ def check_log_return_types(self, host_out: typing.List[str]):
         self.assertIn("Return string", host_out)
         self.assertIn("Return bytes", host_out)
         self.assertIn("Return dict", host_out)
+        self.assertIn("Return list", host_out)
 
         # Checks for failed executions
         errors_found = False