Merge pull request #305367 from JKirsch1/update-durable-orchestration-code

Freshness Edit: Azure Functions

Author: JillGrant615

articles/azure-functions/durable/durable-functions-orchestrations.md

@@ -122,9 +122,9 @@ df.app.orchestration("helloSequence", function* (context) {
     const output = [];
     output.push(yield context.df.callActivity(helloActivityName, "Tokyo"));
     output.push(yield context.df.callActivity(helloActivityName, "Seattle"));
-    output.push(yield context.df.callActivity(helloActivityName, "Cairo"));
+    output.push(yield context.df.callActivity(helloActivityName, "London"));
 
-    // returns ["Hello Tokyo!", "Hello Seattle!", "Hello Cairo!"]
+    // Return ["Hello Tokyo!", "Hello Seattle!", "Hello London!"].
     return output;
 });
 ```
@@ -135,13 +135,21 @@ df.app.orchestration("helloSequence", function* (context) {
 import azure.functions as func
 import azure.durable_functions as df
 
+# Create a FunctionApp instance.
+app = df.DFApp(http_auth_level=func.AuthLevel.ANONYMOUS)
+
+# Orchestrator
+@app.orchestration_trigger(context_name="context")
 def orchestrator_function(context: df.DurableOrchestrationContext):
     result1 = yield context.call_activity('SayHello', "Tokyo")
     result2 = yield context.call_activity('SayHello', "Seattle")
     result3 = yield context.call_activity('SayHello', "London")
     return [result1, result2, result3]
 
-main = df.Orchestrator.create(orchestrator_function)
+# Activity
+@app.activity_trigger(input_name="city")
+def SayHello(city: str):
+    return f"Hello {city}"
 ```
 
 # [PowerShell](#tab/powershell)
@@ -320,8 +328,11 @@ public static async Task CheckSiteAvailable(
     Uri url = context.GetInput<Uri>();
 
     // Makes an HTTP GET request to the specified endpoint
-    DurableHttpResponse response =
-        await context.CallHttpAsync(HttpMethod.Get, url);
+    DurableHttpResponse response = await context.CallHttpAsync(
+        method: HttpMethod.Get,
+        uri: url,
+        content: null,
+        retryOptions: null);
 
     if ((int)response.StatusCode == 400)
     {
@@ -364,11 +375,14 @@ df.app.orchestration("checkSiteAvailable", function* (context) {
 import azure.functions as func
 import azure.durable_functions as df
 
+app = df.DFApp(http_auth_level=func.AuthLevel.ANONYMOUS)
+
+@app.orchestration_trigger(context_name="context")
 def orchestrator_function(context: df.DurableOrchestrationContext):
     url = context.get_input()
     res = yield context.call_http('GET', url)
-    if res.status_code >= 400:
-        # handing of error code goes here
+    if res['statusCode'] >= 400:
+        # Handle error codes.
 ```
 
 # [PowerShell](#tab/powershell)
@@ -436,28 +450,28 @@ public static async Task<object> Mapper([ActivityTrigger] IDurableActivityContex
 In .NET you can also use [ValueTuple](/dotnet/csharp/tuples) objects. The following sample is using new features of [ValueTuple](/dotnet/csharp/tuples) added with [C# 7](/dotnet/csharp/whats-new/csharp-7#tuples):
 
 ```csharp
+public record CourseInfo(string Major, int UniversityYear);
+
 [Function("GetCourseRecommendations")]
 public static async Task<object> RunOrchestrator(
     [OrchestrationTrigger] TaskOrchestrationContext context, int universityYear)
 {
-    string major = "ComputerScience";
-
+    CourseInfo courseInfo = new("ComputerScience", universityYear);
     object courseRecommendations = await context.CallActivityAsync<object>(
-        "CourseRecommendations",
-        (major, universityYear));
+        "CourseRecommendations", courseInfo);
     return courseRecommendations;
 }
 
-[FunctionName("CourseRecommendations")]
-public static async Task<object> Mapper(
-    [ActivityTrigger] (string Major, int UniversityYear) studentInfo, FunctionContext executionContext)
+[Function("CourseRecommendations")]
+public static async Task<CourseInfo> Mapper(
+    [ActivityTrigger] CourseInfo studentInfo, FunctionContext executionContext)
 {
-    // retrieve and return course recommendations by major and university year
+    // Retrieve and return course recommendations by major and university year.
     return new
     {
         major = studentInfo.Major,
         universityYear = studentInfo.UniversityYear,
-        recommendedCourses = new []
+        recommendedCourses = new[]
         {
             "Introduction to .NET Programming",
             "Introduction to Linux",
@@ -485,7 +499,7 @@ module.exports = df.orchestrator(function*(context) {
 });
 ```
 
-#### `GetWeather` Activity
+#### GetWeather activity
 
 ```javascript
 module.exports = async function (context, location) {
@@ -511,39 +525,37 @@ df.app.orchestration("getWeatherOrchestrator", function* (context) {
     // ...
 });
 
-df.app.activity(getWeatherActivityName, async function (location) {
-    const { city, state } = location; // destructure properties into variables
+df.app.activity(getWeatherActivityName, {
+    handler: async (input) => {
+        const { city, state } = input; // Destructure properties into variables.
 
-    // ...
+        // ...
+    }
 });
 ```
 
 # [Python](#tab/python)
 
-#### Orchestrator
-
 ```python
 from collections import namedtuple
 import azure.functions as func
 import azure.durable_functions as df
 
+# Create a FunctionApp instance.
+app = df.DFApp(http_auth_level=func.AuthLevel.ANONYMOUS)
+
+# Orchestrator
+@app.orchestration_trigger(context_name="context")
 def orchestrator_function(context: df.DurableOrchestrationContext):
     Location = namedtuple('Location', ['city', 'state'])
     location = Location(city='Seattle', state= 'WA')
 
     weather = yield context.call_activity("GetWeather", location)
-
     # ...
 
-```
-#### `GetWeather` Activity
-
-```python
-from collections import namedtuple
-
-Location = namedtuple('Location', ['city', 'state'])
-
-def main(location: Location) -> str:
+# Activity
+@app.activity_trigger(input_name="location")
+def GetWeather(location):
     city, state = location
     return f"Hello {city}, {state}!"
 ```