Skip to content

Commit

Permalink
Merge pull request #116 from Chaithra-07/main
Browse files Browse the repository at this point in the history
Changes to support methods with worker attributes.
  • Loading branch information
v1r3n authored Apr 30, 2024
2 parents e86fafc + 9954f87 commit 71c5017
Show file tree
Hide file tree
Showing 18 changed files with 941 additions and 15 deletions.
4 changes: 4 additions & 0 deletions Conductor/Client/Constants.cs
Original file line number Diff line number Diff line change
Expand Up @@ -67,5 +67,9 @@ public static class Constants
public const string PINECONEENDPOINT = "PINECONE_ENDPOINT";
public const string PINECONEAPIKEY = "PINECONE_API_KEY";
public const string OPENAIAPIKEY = "OPENAI_API_KEY";

//Annotation
public const string TOKENCANCELLATION = "Token Requested Cancel";
public const string RUNTIMEERROR = "Method failed with runtime error";
}
}
18 changes: 13 additions & 5 deletions Conductor/Client/Models/TaskResult.cs
Original file line number Diff line number Diff line change
@@ -1,12 +1,11 @@
using System.Linq;
using System.IO;
using Newtonsoft.Json;
using Newtonsoft.Json.Converters;
using System;
using System.Text;
using System.Collections.Generic;
using System.Runtime.Serialization;
using Newtonsoft.Json;
using System.ComponentModel.DataAnnotations;
using System.Linq;
using System.Runtime.Serialization;
using System.Text;

namespace Conductor.Client.Models
{
Expand Down Expand Up @@ -152,6 +151,15 @@ public override string ToString()
return sb.ToString();
}

/// <summary>
/// Method to set the value for callbackAfterSeconds
/// </summary>
/// <param name="callbackAfterSeconds"></param>
public void SetCallbackAfterSeconds(long callbackAfterSeconds)
{
this.CallbackAfterSeconds = callbackAfterSeconds;
}

/// <summary>
/// Returns the JSON string presentation of the object
/// </summary>
Expand Down
17 changes: 17 additions & 0 deletions Conductor/Client/Models/WorkflowTask.cs
Original file line number Diff line number Diff line change
Expand Up @@ -755,5 +755,22 @@ public override int GetHashCode()
{
yield break;
}
/// <summary>
/// Sets theDynamicForkJoinTasksParam
/// </summary>
/// <param name="dynamicForkTasksParam"></param>
public void SetDynamicForkJoinTasksParam(string dynamicForkTasksParam)
{
this.DynamicForkJoinTasksParam = dynamicForkTasksParam;
}

/// <summary>
/// Sets the dynamicForkTasksInputParamName
/// </summary>
/// <param name="dynamicForkTasksInputParamName"></param>
public void SetDynamicForkTasksInputParamName(string dynamicForkTasksInputParamName)
{
this.DynamicForkTasksInputParamName = dynamicForkTasksInputParamName;
}
}
}
Loading

0 comments on commit 71c5017

Please sign in to comment.