fix errors

Author: lucyzhang929

tests/endtoend/sql_functions/sql_functions_stein/function_app.py

@@ -9,11 +9,12 @@
 
 @app.route(route="sql_input/{productid}")
 @app.sql_input(arg_name="products",
-                command_text="SELECT * FROM Products WHERE ProductId = @ProductId",
-                command_type="Text",
-                parameters="@ProductId={productid}"
-                connection_string_setting="AzureWebJobsSqlConnectionString")
-def sql_input(req: func.HttpRequest, products: func.SqlRowList) -> func.HttpResponse:
+               command_text="SELECT * FROM Products WHERE ProductId = @ProductId",
+               command_type="Text",
+               parameters="@ProductId={productid}",
+               connection_string_setting="AzureWebJobsSqlConnectionString")
+def sql_input(req: func.HttpRequest, products: func.SqlRowList) \
+        -> func.HttpResponse:
     rows = list(map(lambda r: json.loads(r.to_json()), products))
 
     return func.HttpResponse(
@@ -22,13 +23,14 @@ def sql_input(req: func.HttpRequest, products: func.SqlRowList) -> func.HttpResp
         mimetype="application/json"
     )
 
+
 @app.route(route="sql_input2/{productid}")
-@app.sql_input(arg_name="products",
+@app.sql_input2(arg_name="products",
                 command_text="SELECT * FROM Products2 WHERE ProductId = @ProductId",
                 command_type="Text",
-                parameters="@ProductId={productid}"
+                parameters="@ProductId={productid}",
                 connection_string_setting="AzureWebJobsSqlConnectionString")
-def sql_input(req: func.HttpRequest, products: func.SqlRowList) -> func.HttpResponse:
+def sql_input2(req: func.HttpRequest, products: func.SqlRowList) -> func.HttpResponse:
     rows = list(map(lambda r: json.loads(r.to_json()), products))
 
     return func.HttpResponse(
@@ -37,11 +39,12 @@ def sql_input(req: func.HttpRequest, products: func.SqlRowList) -> func.HttpResp
         mimetype="application/json"
     )
 
+
 @app.route()
 @app.sql_output(arg_name="r",
                 command_text="[dbo].[Products]",
                 connection_string_setting="AzureWebJobsSqlConnectionString")
-def sql_output(req: func.HttpRequest, product: func.Out[func.SqlRow]) -> func.HttpResponse:
+def sql_output(req: func.HttpRequest, r: func.Out[func.SqlRow]) -> func.HttpResponse:
     body = json.loads(req.get_body())
     row = func.SqlRow.from_dict(body)
     r.set(row)
@@ -52,6 +55,7 @@ def sql_output(req: func.HttpRequest, product: func.Out[func.SqlRow]) -> func.Ht
         mimetype="application/json"
     )
 
+
 @app.sql_trigger(arg_name="changes",
                  table_name="Products",
                  connection_string_setting="AzureWebJobsSqlConnectionString")
@@ -61,4 +65,4 @@ def sql_output(req: func.HttpRequest, product: func.Out[func.SqlRow]) -> func.Ht
 def sql_trigger(changes, r: func.Out[func.SqlRow]) -> str:
     row = func.SqlRow.from_dict(json.loads(changes)[0]["Item"])
     r.set(row)
-    return "OK"
+    return "OK"

tests/endtoend/sql_functions/sql_functions_stein/generic/function_app.py

@@ -10,10 +10,11 @@
 @app.generic_trigger(arg_name="req", type="httpTrigger", route="sql_input/{productid}")
 @app.generic_output_binding(arg_name="$return", type="http")
 @app.generic_input_binding(arg_name="products", type="sql",
-                command_text="SELECT * FROM Products WHERE ProductId = @ProductId",
-                command_type="Text",
-                parameters="@ProductId={productid}"
-                connection_string_setting="AzureWebJobsSqlConnectionString")
+                           command_text="SELECT * FROM Products"
+                           "WHERE ProductId = @ProductId",
+                           command_type="Text",
+                           parameters="@ProductId={productid}",
+                           connection_string_setting="AzureWebJobsSqlConnectionString")
 def sql_input(req: func.HttpRequest, products: func.SqlRowList) -> func.HttpResponse:
     rows = list(map(lambda r: json.loads(r.to_json()), products))
 
@@ -23,14 +24,16 @@ def sql_input(req: func.HttpRequest, products: func.SqlRowList) -> func.HttpResp
         mimetype="application/json"
     )
 
+
 @app.generic_trigger(arg_name="req", type="httpTrigger", route="sql_input2/{productid}")
 @app.generic_output_binding(arg_name="$return", type="http")
 @app.generic_input_binding(arg_name="products", type="sql",
-                command_text="SELECT * FROM Products2 WHERE ProductId = @ProductId",
-                command_type="Text",
-                parameters="@ProductId={productid}"
-                connection_string_setting="AzureWebJobsSqlConnectionString")
-def sql_input(req: func.HttpRequest, products: func.SqlRowList) -> func.HttpResponse:
+                           command_text="SELECT * FROM Products2 "
+                           "WHERE ProductId = @ProductId",
+                           command_type="Text",
+                           parameters="@ProductId={productid}",
+                           connection_string_setting="AzureWebJobsSqlConnectionString")
+def sql_input2(req: func.HttpRequest, products: func.SqlRowList) -> func.HttpResponse:
     rows = list(map(lambda r: json.loads(r.to_json()), products))
 
     return func.HttpResponse(
@@ -39,12 +42,15 @@ def sql_input(req: func.HttpRequest, products: func.SqlRowList) -> func.HttpResp
         mimetype="application/json"
     )
 
+
 @app.generic_trigger(arg_name="req", type="httpTrigger")
 @app.generic_output_binding(arg_name="$return", type="http")
 @app.generic_output_binding(arg_name="r", type="sql",
-                command_text="[dbo].[Products]",
-                connection_string_setting="AzureWebJobsSqlConnectionString")
-def sql_output(req: func.HttpRequest, product: func.Out[func.SqlRow]) -> func.HttpResponse:
+                            command_text="[dbo].[Products]",
+                            connection_string_setting="AzureWebJobs"
+                            "SqlConnectionString")
+def sql_output(req: func.HttpRequest, r: func.Out[func.SqlRow]) \
+        -> func.HttpResponse:
     body = json.loads(req.get_body())
     row = func.SqlRow.from_dict(body)
     r.set(row)
@@ -55,13 +61,14 @@ def sql_output(req: func.HttpRequest, product: func.Out[func.SqlRow]) -> func.Ht
         mimetype="application/json"
     )
 
+
 @app.generic_trigger(arg_name="changes", type="sqlTrigger",
-                 table_name="Products",
-                 connection_string_setting="AzureWebJobsSqlConnectionString")
+                     table_name="Products",
+                     connection_string_setting="AzureWebJobsSqlConnectionString")
 @app.generic_output_binding(arg_name="r", type="sql",
-                command_text="[dbo].[Products2]",
-                connection_string_setting="AzureWebJobsSqlConnectionString")
+                            command_text="[dbo].[Products2]",
+                            connection_string_setting="AzureWebJobsSqlConnectionString")
 def sql_trigger(changes, r: func.Out[func.SqlRow]) -> str:
     row = func.SqlRow.from_dict(json.loads(changes)[0]["Item"])
     r.set(row)
-    return "OK"
+    return "OK"

tests/endtoend/test_sql_functions.py

@@ -51,6 +51,7 @@ def test_sql_binding_trigger(self):
             else:
                 break
 
+
 class TestSqlFunctionsStein(TestSqlFunctions):
 
     @classmethod
@@ -64,4 +65,4 @@ class TestSqlFunctionsSteinGeneric(TestSqlFunctions):
     @classmethod
     def get_script_dir(cls):
         return testutils.E2E_TESTS_FOLDER / 'sql_functions' / \
-            'sql_functions_stein' / 'generic'
+            'sql_functions_stein' / 'generic'