diff --git a/setup.py b/setup.py
index dceb9be07..766431b0e 100644
--- a/setup.py
+++ b/setup.py
@@ -41,7 +41,7 @@
       <PackageReference Include="Microsoft.NET.Sdk.Functions"
         Version="4.0.1" />
       <PackageReference Include="Microsoft.Azure.WebJobs.Extensions.CosmosDB"
-        Version="3.0.10" />
+        Version="4.2.0" />
       <PackageReference Include="Microsoft.Azure.WebJobs.Extensions.EventHubs"
         Version="5.0.0" />
       <PackageReference Include="Microsoft.Azure.WebJobs.Extensions.EventGrid"
diff --git a/tests/endtoend/cosmosdb_functions/cosmosdb_functions_stein/function_app.py b/tests/endtoend/cosmosdb_functions/cosmosdb_functions_stein/function_app.py
index 715e226a9..c0ddcaad1 100644
--- a/tests/endtoend/cosmosdb_functions/cosmosdb_functions_stein/function_app.py
+++ b/tests/endtoend/cosmosdb_functions/cosmosdb_functions_stein/function_app.py
@@ -8,19 +8,19 @@
 @app.route()
 @app.cosmos_db_input(
     arg_name="docs", database_name="test",
-    collection_name="items",
+    container_name="items",
     id="cosmosdb-input-test",
-    connection_string_setting="AzureWebJobsCosmosDBConnectionString")
+    connection="AzureWebJobsCosmosDBConnectionString")
 def cosmosdb_input(req: func.HttpRequest, docs: func.DocumentList) -> str:
     return func.HttpResponse(docs[0].to_json(), mimetype='application/json')
 
 
 @app.cosmos_db_trigger(
     arg_name="docs", database_name="test",
-    collection_name="items",
-    lease_collection_name="leases",
-    connection_string_setting="AzureWebJobsCosmosDBConnectionString",
-    create_lease_collection_if_not_exists=True)
+    container_name="items",
+    lease_container_name="leases",
+    connection="AzureWebJobsCosmosDBConnectionString",
+    create_lease_container_if_not_exists=True)
 @app.blob_output(arg_name="$return", connection="AzureWebJobsStorage",
                  path="python-worker-tests/test-cosmosdb-triggered.txt")
 def cosmosdb_trigger(docs: func.DocumentList) -> str:
@@ -38,10 +38,9 @@ def get_cosmosdb_triggered(req: func.HttpRequest,
 @app.route()
 @app.cosmos_db_output(
     arg_name="doc", database_name="test",
-    collection_name="items",
+    container_name="items",
     create_if_not_exists=True,
-    connection_string_setting="AzureWebJobsCosmosDBConnectionString")
+    connection="AzureWebJobsCosmosDBConnectionString")
 def put_document(req: func.HttpRequest, doc: func.Out[func.Document]):
     doc.set(func.Document.from_json(req.get_body()))
-
     return 'OK'
diff --git a/tests/endtoend/cosmosdb_functions/cosmosdb_functions_stein/generic/function_app.py b/tests/endtoend/cosmosdb_functions/cosmosdb_functions_stein/generic/function_app.py
index 66b50ba91..baf665be6 100644
--- a/tests/endtoend/cosmosdb_functions/cosmosdb_functions_stein/generic/function_app.py
+++ b/tests/endtoend/cosmosdb_functions/cosmosdb_functions_stein/generic/function_app.py
@@ -11,9 +11,9 @@
     arg_name="docs",
     type="cosmosDB",
     database_name="test",
-    collection_name="items",
+    container_name="items",
     id="cosmosdb-input-test",
-    connection_string_setting="AzureWebJobsCosmosDBConnectionString")
+    connection="AzureWebJobsCosmosDBConnectionString")
 def cosmosdb_input(req: func.HttpRequest, docs: func.DocumentList) -> str:
     return func.HttpResponse(docs[0].to_json(), mimetype='application/json')
 
@@ -22,10 +22,10 @@ def cosmosdb_input(req: func.HttpRequest, docs: func.DocumentList) -> str:
     arg_name="docs",
     type="cosmosDBTrigger",
     database_name="test",
-    collection_name="items",
-    lease_collection_name="leases",
-    connection_string_setting="AzureWebJobsCosmosDBConnectionString",
-    create_lease_collection_if_not_exists=True)
+    container_name="items",
+    lease_container_name="leases",
+    connection="AzureWebJobsCosmosDBConnectionString",
+    create_lease_container_if_not_exists=True)
 @app.generic_output_binding(
     arg_name="$return",
     type="blob",
@@ -53,10 +53,9 @@ def get_cosmosdb_triggered(req: func.HttpRequest,
     arg_name="doc",
     database_name="test",
     type="cosmosDB",
-    collection_name="items",
+    container_name="items",
     create_if_not_exists=True,
-    connection_string_setting="AzureWebJobsCosmosDBConnectionString")
+    connection="AzureWebJobsCosmosDBConnectionString")
 def put_document(req: func.HttpRequest, doc: func.Out[func.Document]):
     doc.set(func.Document.from_json(req.get_body()))
-
     return 'OK'
diff --git a/tests/endtoend/cosmosdb_functions/cosmosdb_input/function.json b/tests/endtoend/cosmosdb_functions/cosmosdb_input/function.json
index 54b7de280..23608f043 100644
--- a/tests/endtoend/cosmosdb_functions/cosmosdb_input/function.json
+++ b/tests/endtoend/cosmosdb_functions/cosmosdb_input/function.json
@@ -13,11 +13,11 @@
       "type": "cosmosDB",
       "name": "docs",
       "databaseName": "test",
-      "collectionName": "items",
+      "containerName": "items",
       "id": "cosmosdb-input-test",
-      "leaseCollectionName": "leases",
-      "connectionStringSetting": "AzureWebJobsCosmosDBConnectionString",
-      "createLeaseCollectionIfNotExists": true
+      "leaseContainerName": "leases",
+      "connection": "AzureWebJobsCosmosDBConnectionString",
+      "createLeaseContainerIfNotExists": true
     },
     {
       "type": "http",
diff --git a/tests/endtoend/cosmosdb_functions/cosmosdb_trigger/function.json b/tests/endtoend/cosmosdb_functions/cosmosdb_trigger/function.json
index 6b557558a..76a24c07d 100644
--- a/tests/endtoend/cosmosdb_functions/cosmosdb_trigger/function.json
+++ b/tests/endtoend/cosmosdb_functions/cosmosdb_trigger/function.json
@@ -7,11 +7,11 @@
       "type": "cosmosDBTrigger",
       "name": "docs",
       "databaseName": "test",
-      "collectionName": "items",
+      "containerName": "items",
       "id": "cosmosdb-trigger-test",
-      "leaseCollectionName": "leases",
-      "connectionStringSetting": "AzureWebJobsCosmosDBConnectionString",
-      "createLeaseCollectionIfNotExists": true
+      "leaseContainerName": "leases",
+      "connection": "AzureWebJobsCosmosDBConnectionString",
+      "createLeaseContainerIfNotExists": true
     },
     {
       "type": "blob",
diff --git a/tests/endtoend/cosmosdb_functions/put_document/function.json b/tests/endtoend/cosmosdb_functions/put_document/function.json
index c232c3659..b385fbfd5 100644
--- a/tests/endtoend/cosmosdb_functions/put_document/function.json
+++ b/tests/endtoend/cosmosdb_functions/put_document/function.json
@@ -13,10 +13,10 @@
       "type": "cosmosDB",
       "name": "doc",
       "databaseName": "test",
-      "collectionName": "items",
-      "leaseCollectionName": "leases",
-      "createLeaseCollectionIfNotExists": true,
-      "connectionStringSetting": "AzureWebJobsCosmosDBConnectionString",
+      "containerName": "items",
+      "leaseContainerName": "leases",
+      "createLeaseContainerIfNotExists": true,
+      "connection": "AzureWebJobsCosmosDBConnectionString",
       "createIfNotExists": true
     },
     {