Extending execution context for retries

Author: alrod

Worker.nuspec

@@ -2,7 +2,7 @@
 <package xmlns="http://schemas.microsoft.com/packaging/2012/06/nuspec.xsd">
   <metadata>
     <id>Microsoft.Azure.Functions.NodeJsWorker</id>
-    <version>2.1.0$version$</version>
+    <version>2.1.1$version$</version>
     <authors>Microsoft</authors>
     <owners>Microsoft</owners>
     <requireLicenseAcceptance>false</requireLicenseAcceptance>

azure-functions-language-worker-protobuf/src/proto/FunctionRpc.proto

@@ -263,6 +263,12 @@ message InvocationRequest {
 
   // Populates activityId, tracestate and tags from host
   RpcTraceContext trace_context = 5;
+
+  // current retry count
+  int32 retry_count = 6;
+
+  // max retry count
+  int32 max_retry_count = 7;  
 }
 
 // Host sends ActivityId, traceStateString and Tags from host

azure-pipelines.yml

@@ -1,5 +1,5 @@
 variables: {
-  WORKER_VERSION: '2.1.0',
+  WORKER_VERSION: '2.1.1',
   NODE_8: '8.x',
   NODE_10: '10.x',
   NODE_12: '12.x',

e2e-nightly-cli-azure-pipelines.yml

@@ -1,5 +1,5 @@
 variables: {
-  WORKER_VERSION: '2.1.0',
+  WORKER_VERSION: '2.1.1',
   NODE_12: '12.x'
 }
 name: $(WORKER_VERSION)-$(Date:yyyyMMdd)$(Rev:.r)

e2e-nightly-site-azure-pipelines.yml

@@ -1,5 +1,5 @@
 variables: {
-  WORKER_VERSION: '2.1.0',
+  WORKER_VERSION: '2.1.1',
   NODE_12: '12.x'
 }
 name: $(WORKER_VERSION)-$(Date:yyyyMMdd)$(Rev:.r)

src/Context.ts

@@ -75,7 +75,9 @@ class InvocationContext implements Context {
         const executionContext = {
             invocationId: this.invocationId,
             functionName: <string>info.name,
-            functionDirectory: <string>info.directory
+            functionDirectory: <string>info.directory,
+            retryCount: <number>request.retryCount,
+            maxRetryCount: <number>request.maxRetryCount
         };
         this.executionContext = executionContext;
         this.bindings = {};

src/public/Interfaces.ts

@@ -157,6 +157,14 @@ export interface ExecutionContext {
      * The directory your function is in (this is the parent directory of this function's function.json).
      */
     functionDirectory: string;
+    /**
+     * Current retry count.
+     */
+    retryCount: number;
+    /**
+     * Current retry count.
+     */
+    maxRetryCount: number;
 }
 
 /**

types/public/Interfaces.d.ts

@@ -155,6 +155,14 @@ export interface ExecutionContext {
      * The directory your function is in (this is the parent directory of this function's function.json).
      */
     functionDirectory: string;
+    /**
+     * Current retry count.
+     */
+    retryCount: number;
+    /**
+     * Current retry count.
+     */
+    maxRetryCount: number;
 }
 /**
  * TraceContext information to enable distributed tracing scenarios.