C# SDK: task-update-v2, OSS auth, interceptors, high-level clients, schema registration

.github/workflows/pull_request.yml

@@ -32,11 +32,7 @@ jobs:
     steps:
       - name: Checkout
         uses: actions/checkout@v4
-      - name: Setup .NET
-        uses: actions/setup-dotnet@v4
-        with:
-          dotnet-version: '8.0.x'
-      - name: Run unit tests
+      - name: Test and collect coverage
         run: >
           dotnet test Tests/conductor-csharp.test.csproj
           -p:DefineConstants=EXCLUDE_EXAMPLE_WORKERS
@@ -55,59 +51,23 @@ jobs:
         uses: codecov/codecov-action@v5
         with:
           token: ${{ secrets.CODECOV_TOKEN }}
-          files: coverage/**/coverage.cobertura.xml
+          files: coverage/out/coverage.cobertura.xml
           flags: unittests
           name: ${{ github.workflow }}-${{ github.job }}-${{ github.run_number }}
 
   integration_tests:
     needs: lint
     runs-on: ubuntu-latest
-    env:
-      CONDUCTOR_SERVER_URL: ${{ secrets.CONDUCTOR_SERVER_URL }}
-      CONDUCTOR_AUTH_KEY: ${{ secrets.CONDUCTOR_AUTH_KEY }}
-      CONDUCTOR_AUTH_SECRET: ${{ secrets.CONDUCTOR_AUTH_SECRET }}
-      GITHUB_RUN_ID: ${{ github.run_id }}
     steps:
       - name: Checkout
         uses: actions/checkout@v4
       - name: Setup .NET
         uses: actions/setup-dotnet@v4
         with:
           dotnet-version: '8.0.x'
-      - name: Show server endpoint and auth key prefix
-        run: |
-          echo "CONDUCTOR_SERVER_URL=${CONDUCTOR_SERVER_URL#*://}"
-          echo "CONDUCTOR_AUTH_KEY prefix=${CONDUCTOR_AUTH_KEY:0:8}..."
-      - name: Run integration tests (v5)
+      - name: Run integration tests
         run: >
           dotnet test Tests/conductor-csharp.test.csproj
           -p:DefineConstants=EXCLUDE_EXAMPLE_WORKERS
           --filter "Category=Integration"
           -l "console;verbosity=normal"
-
-  legacy_integration_tests:
-    needs: lint
-    runs-on: ubuntu-latest
-    env:
-      CONDUCTOR_SERVER_URL: ${{ secrets.CONDUCTOR_SERVER_URL }}
-      CONDUCTOR_AUTH_KEY: ${{ secrets.CONDUCTOR_AUTH_KEY }}
-      CONDUCTOR_AUTH_SECRET: ${{ secrets.CONDUCTOR_AUTH_SECRET }}
-      GITHUB_RUN_ID: ${{ github.run_id }}
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v4
-      - name: Setup .NET
-        uses: actions/setup-dotnet@v4
-        with:
-          dotnet-version: '8.0.x'
-      - name: Show server endpoint and auth key prefix
-        run: |
-          echo "CONDUCTOR_SERVER_URL=${CONDUCTOR_SERVER_URL#*://}"
-          echo "CONDUCTOR_AUTH_KEY prefix=${CONDUCTOR_AUTH_KEY:0:8}..."
-      - name: Run legacy integration tests
-        run: >
-          dotnet test Tests/conductor-csharp.test.csproj
-          -p:DefineConstants=EXCLUDE_EXAMPLE_WORKERS
-          --filter "Category=CloudIntegration"
-          -l "console;verbosity=normal"
-

Conductor/Api/ITaskResourceApi.cs

@@ -241,6 +241,15 @@ public interface ITaskResourceApi : IApiAccessor
         Workflow UpdateTaskSync(Dictionary<string, Object> output, string workflowId, string taskRefName, TaskResult.StatusEnum status, string workerid = null);
 
 
+        /// <summary>
+        /// Update a task (v2) — updates the result and returns the next available task in one call.
+        /// Supported on newer Conductor servers. Falls back gracefully on older servers.
+        /// </summary>
+        /// <param name="body">Task result to submit</param>
+        /// <param name="workerid">Worker identifier (optional)</param>
+        /// <returns>Next task to process, or null if none available or server does not support v2</returns>
+        Task UpdateTaskV2(TaskResult body, string workerid = null);
+
         #endregion Synchronous Operations
 
         #region Asynchronous Operations
@@ -459,6 +468,11 @@ public interface ITaskResourceApi : IApiAccessor
         /// <returns>Workflow</returns>
         ThreadTask.Task<Workflow> UpdateTaskSyncAsync(Dictionary<string, Object> output, string workflowId, string taskRefName, TaskResult.StatusEnum status, string workerid = null);
 
+        /// <summary>
+        /// Asynchronous update a task (v2) — updates the result and returns the next available task.
+        /// </summary>
+        ThreadTask.Task<Task> UpdateTaskV2Async(TaskResult body, string workerid = null);
+
         #endregion Asynchronous Operations
     }
 }

Conductor/Api/TaskResourceApi.cs

@@ -1426,7 +1426,101 @@
         }
 
         /// <summary>
-        /// Update a task By Ref Name 
+        /// Update a task (v2) — submits the result and returns the next available task in one call.
+        /// Uses PUT /tasks/{taskId} which is supported on newer Conductor servers.
+        /// Returns null if no next task is available or the server returns a non-task response.
+        /// Throws ApiException with ErrorCode 404/405 on older servers (caller should fall back to v1).
+        /// </summary>
+        public Task UpdateTaskV2(TaskResult body, string workerid = null)
+        {
+            if (body == null)
+                throw new ApiException(400, "Missing required parameter 'body' when calling TaskResourceApi->UpdateTaskV2");
+
+            var localVarPath = "/tasks/{taskId}";
+            var localVarPathParams = new Dictionary<String, String>();
+            var localVarQueryParams = new List<KeyValuePair<String, String>>();
+            var localVarHeaderParams = new Dictionary<String, String>(this.Configuration.DefaultHeader);
+            var localVarFormParams = new Dictionary<String, String>();
+            var localVarFileParams = new Dictionary<String, FileParameter>();
+
+            localVarPathParams["taskId"] = this.Configuration.ApiClient.ParameterToString(body.TaskId);
+            if (workerid != null) localVarQueryParams.AddRange(this.Configuration.ApiClient.ParameterToKeyValuePairs("", "workerid", workerid));
+
+            String localVarHttpContentType = this.Configuration.ApiClient.SelectHeaderContentType(new[] { "application/json" });
+            String localVarHttpHeaderAccept = this.Configuration.ApiClient.SelectHeaderAccept(new[] { "application/json" });
+            if (localVarHttpHeaderAccept != null)
+                localVarHeaderParams.Add("Accept", localVarHttpHeaderAccept);
+
+            Object localVarPostBody = this.Configuration.ApiClient.Serialize(body);
+
+            if (!String.IsNullOrEmpty(this.Configuration.AccessToken))
+                localVarHeaderParams["X-Authorization"] = this.Configuration.AccessToken;
+
+            RestResponse localVarResponse = (RestResponse)this.Configuration.ApiClient.CallApi(
+                localVarPath, Method.Put, localVarQueryParams, localVarPostBody,
+                localVarHeaderParams, localVarFormParams, localVarFileParams,
+                localVarPathParams, localVarHttpContentType, this.Configuration);
+
+            int localVarStatusCode = (int)localVarResponse.StatusCode;
+
+            if (ExceptionFactory != null)
+            {
+                Exception exception = ExceptionFactory("UpdateTaskV2", localVarResponse);
+                if (exception != null) throw exception;
+            }
+
+            if (string.IsNullOrWhiteSpace(localVarResponse.Content) || localVarResponse.Content == "null")
+                return null;
+
+            return (Task)this.Configuration.ApiClient.Deserialize(localVarResponse, typeof(Task));
+        }
+
+        public async ThreadTask.Task<Task> UpdateTaskV2Async(TaskResult body, string workerid = null)
+        {
+            if (body == null)
+                throw new ApiException(400, "Missing required parameter 'body' when calling TaskResourceApi->UpdateTaskV2Async");
+
+            var localVarPath = "/tasks/{taskId}";
+            var localVarPathParams = new Dictionary<String, String>();
+            var localVarQueryParams = new List<KeyValuePair<String, String>>();
+            var localVarHeaderParams = new Dictionary<String, String>(this.Configuration.DefaultHeader);
+            var localVarFormParams = new Dictionary<String, String>();
+            var localVarFileParams = new Dictionary<String, FileParameter>();
+
+            localVarPathParams["taskId"] = this.Configuration.ApiClient.ParameterToString(body.TaskId);
+            if (workerid != null) localVarQueryParams.AddRange(this.Configuration.ApiClient.ParameterToKeyValuePairs("", "workerid", workerid));
+
+            String localVarHttpContentType = this.Configuration.ApiClient.SelectHeaderContentType(new[] { "application/json" });
+            String localVarHttpHeaderAccept = this.Configuration.ApiClient.SelectHeaderAccept(new[] { "application/json" });
+            if (localVarHttpHeaderAccept != null)
+                localVarHeaderParams.Add("Accept", localVarHttpHeaderAccept);
+
+            Object localVarPostBody = this.Configuration.ApiClient.Serialize(body);
+
+            if (!String.IsNullOrEmpty(this.Configuration.AccessToken))
+                localVarHeaderParams["X-Authorization"] = this.Configuration.AccessToken;
+
+            RestResponse localVarResponse = (RestResponse)await this.Configuration.ApiClient.CallApiAsync(
+                localVarPath, Method.Put, localVarQueryParams, localVarPostBody,
+                localVarHeaderParams, localVarFormParams, localVarFileParams,
+                localVarPathParams, localVarHttpContentType);
+
+            int localVarStatusCode = (int)localVarResponse.StatusCode;
+
+            if (ExceptionFactory != null)
+            {
+                Exception exception = ExceptionFactory("UpdateTaskV2Async", localVarResponse);
+                if (exception != null) throw exception;
+            }
+
+            if (string.IsNullOrWhiteSpace(localVarResponse.Content) || localVarResponse.Content == "null")
+                return null;
+
+            return (Task)this.Configuration.ApiClient.Deserialize(localVarResponse, typeof(Task));
+        }
+
+        /// <summary>
+        /// Update a task By Ref Name
         /// </summary>
         /// <exception cref="Conductor.Client.ApiException">Thrown when fails to make API call</exception>
         /// <param name="body"></param>
@@ -1605,7 +1699,7 @@
             if (taskRefName == null)
                 throw new ApiException(400, "Missing required parameter 'taskRefName' when calling TaskResourceApi->UpdateTask");
             // verify the required parameter 'status' is set
             if (status == null)
                 throw new ApiException(400, "Missing required parameter 'status' when calling TaskResourceApi->UpdateTask");
 
             var localVarPath = "/tasks/{workflowId}/{taskRefName}/{status}/sync";
@@ -1637,7 +1731,7 @@
 
             if (workflowId != null) localVarPathParams.Add("workflowId", this.Configuration.ApiClient.ParameterToString(workflowId)); // path parameter
             if (taskRefName != null) localVarPathParams.Add("taskRefName", this.Configuration.ApiClient.ParameterToString(taskRefName)); // path parameter
             if (status != null) localVarPathParams.Add("status", this.Configuration.ApiClient.ParameterToString(status)); // path parameter
             if (workerid != null) localVarQueryParams.AddRange(this.Configuration.ApiClient.ParameterToKeyValuePairs("", "workerid", workerid)); // query parameter
             if (output != null && output.GetType() != typeof(byte[]))
             {

Conductor/Client/Ai/Configuration.cs

@@ -47,6 +47,48 @@ public enum LLMProviderEnum
             /// </summary>
             [EnumMember(Value = "huggingface")]
             HUGGING_FACE = 4,
+
+            /// <summary>
+            /// Enum ANTHROPIC for value: anthropic
+            /// </summary>
+            [EnumMember(Value = "anthropic")]
+            ANTHROPIC = 5,
+
+            /// <summary>
+            /// Enum AWS_BEDROCK for value: aws_bedrock
+            /// </summary>
+            [EnumMember(Value = "aws_bedrock")]
+            AWS_BEDROCK = 6,
+
+            /// <summary>
+            /// Enum COHERE for value: cohere
+            /// </summary>
+            [EnumMember(Value = "cohere")]
+            COHERE = 7,
+
+            /// <summary>
+            /// Enum GROK for value: grok
+            /// </summary>
+            [EnumMember(Value = "grok")]
+            GROK = 8,
+
+            /// <summary>
+            /// Enum MISTRAL for value: mistral
+            /// </summary>
+            [EnumMember(Value = "mistral")]
+            MISTRAL = 9,
+
+            /// <summary>
+            /// Enum OLLAMA for value: ollama
+            /// </summary>
+            [EnumMember(Value = "ollama")]
+            OLLAMA = 10,
+
+            /// <summary>
+            /// Enum PERPLEXITY for value: perplexity
+            /// </summary>
+            [EnumMember(Value = "perplexity")]
+            PERPLEXITY = 11,
         }
 
         /// <summary>
@@ -66,6 +108,18 @@ public enum VectorDBEnum
             /// </summary>
             [EnumMember(Value = "weaviatedb")]
             WEAVIATE_DB = 2,
+
+            /// <summary>
+            /// Enum POSTGRES_DB for value: postgresdb
+            /// </summary>
+            [EnumMember(Value = "postgresdb")]
+            POSTGRES_DB = 3,
+
+            /// <summary>
+            /// Enum MONGO_DB for value: mongodb
+            /// </summary>
+            [EnumMember(Value = "mongodb")]
+            MONGO_DB = 4,
         }
     }
 }