+ * Allows casting this expression to a specific type
+ *
+ *
+ * optional .littlehorse.VariableType type_to_cast_to = 4;
+ * @return Whether the typeToCastTo field is set.
+ */
+ boolean hasTypeToCastTo();
+ /**
+ *
+ * Allows casting this expression to a specific type
+ *
+ *
+ * optional .littlehorse.VariableType type_to_cast_to = 4;
+ * @return The enum numeric value on the wire for typeToCastTo.
+ */
+ int getTypeToCastToValue();
+ /**
+ *
+ * Allows casting this expression to a specific type
+ *
+ * Allows casting this Variable Assignment to a specific type
+ *
+ *
+ * optional .littlehorse.VariableType type_to_cast_to = 7;
+ * @param value The typeToCastTo to set.
+ * @return This builder for chaining.
+ */
+ public Builder setTypeToCastTo(io.littlehorse.sdk.common.proto.VariableType value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000040;
+ typeToCastTo_ = value.getNumber();
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ * Allows casting this Variable Assignment to a specific type
+ *
+ *
+ * optional .littlehorse.VariableType type_to_cast_to = 7;
+ * @return This builder for chaining.
+ */
+ public Builder clearTypeToCastTo() {
+ bitField0_ = (bitField0_ & ~0x00000040);
+ typeToCastTo_ = 0;
+ onChanged();
+ return this;
+ }
@java.lang.Override
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
diff --git a/sdk-java/src/main/java/io/littlehorse/sdk/common/proto/VariableAssignmentOrBuilder.java b/sdk-java/src/main/java/io/littlehorse/sdk/common/proto/VariableAssignmentOrBuilder.java
index a7b17eee3..7735a8fca 100644
--- a/sdk-java/src/main/java/io/littlehorse/sdk/common/proto/VariableAssignmentOrBuilder.java
+++ b/sdk-java/src/main/java/io/littlehorse/sdk/common/proto/VariableAssignmentOrBuilder.java
@@ -179,5 +179,33 @@ public interface VariableAssignmentOrBuilder extends
*/
io.littlehorse.sdk.common.proto.VariableAssignment.ExpressionOrBuilder getExpressionOrBuilder();
+ /**
+ *
+ * Allows casting this Variable Assignment to a specific type
+ *
+ *
+ * optional .littlehorse.VariableType type_to_cast_to = 7;
+ * @return Whether the typeToCastTo field is set.
+ */
+ boolean hasTypeToCastTo();
+ /**
+ *
+ * Allows casting this Variable Assignment to a specific type
+ *
+ *
+ * optional .littlehorse.VariableType type_to_cast_to = 7;
+ * @return The enum numeric value on the wire for typeToCastTo.
+ */
+ int getTypeToCastToValue();
+ /**
+ *
+ * Allows casting this Variable Assignment to a specific type
+ *
+ *
+ * optional .littlehorse.VariableType type_to_cast_to = 7;
+ * @return The typeToCastTo.
+ */
+ io.littlehorse.sdk.common.proto.VariableType getTypeToCastTo();
+
io.littlehorse.sdk.common.proto.VariableAssignment.SourceCase getSourceCase();
}
diff --git a/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/LHExpression.java b/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/LHExpression.java
index e143bc8f9..e23eaf158 100644
--- a/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/LHExpression.java
+++ b/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/LHExpression.java
@@ -80,4 +80,25 @@ public interface LHExpression extends Serializable {
* by `key` removed.
*/
LHExpression removeKey(Serializable key);
+
+ /**
+ * Casts the expression to a string. Returns this LHExpression.
+ *
+ * @return this LHExpression.
+ */
+ LHExpression asStr();
+
+ /**
+ * Casts the expression to an INT. Returns this LHExpression.
+ *
+ * @return this LHExpression.
+ */
+ LHExpression asInt();
+
+ /**
+ * Casts the expression to a double. Returns this LHExpression.
+ *
+ * @return this LHExpression.
+ */
+ LHExpression asDouble();
}
diff --git a/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/NodeOutput.java b/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/NodeOutput.java
index ddb1ea51b..24b4ea36a 100644
--- a/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/NodeOutput.java
+++ b/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/NodeOutput.java
@@ -1,10 +1,12 @@
package io.littlehorse.sdk.wfsdk;
+import java.io.Serializable;
+
/**
* `NodeOutput` represents the output of a Node execution. It can be used to set a timeout on a
* node, or as input for a Variable Mutation.
*/
-public interface NodeOutput extends LHExpression {
+public interface NodeOutput extends Serializable {
/**
* Valid only for output of the JSON_OBJ or JSON_ARR types. Returns a new NodeOutput handle
* which points to Json element referred to by the json path.
@@ -26,4 +28,81 @@ public interface NodeOutput extends LHExpression {
* @return the NodeOutput.
*/
public NodeOutput timeout(int timeoutSeconds);
+
+ /**
+ * Returns an expression whose value is the `other` added to this node's output.
+ * @param other the value to be added to this node's output.
+ * @return an expression whose value is the `other` added to this node's output.
+ */
+ LHExpression add(Serializable other);
+
+ /**
+ * Returns an expression whose value is the `other` subtracted from this node's output.
+ * @param other the value to be subtracted from this node's output.
+ * @return an expression whose value is the `other` subtracted from this node's output.
+ */
+ LHExpression subtract(Serializable other);
+
+ /**
+ * Returns an expression whose value is the `other` multiplied by this node's output.
+ * @param other the value to be multiplied by this node's output.
+ * @return an expression whose value is the `other` multiplied by this node's output.
+ */
+ LHExpression multiply(Serializable other);
+
+ /**
+ * Returns an expression whose value is this node's output divided by the `other`.
+ * @param other the value to divide this node's output by.
+ * @return an expression whose value is this node's output divided by the `other`.
+ */
+ LHExpression divide(Serializable other);
+
+ /**
+ * Returns an expression whose value is this node's output extended by the `other`.
+ * @param other the value to extend this node's output by.
+ * @return an expression whose value is this node's output extended by the `other`.
+ */
+ LHExpression extend(Serializable other);
+
+ /**
+ * Returns an expression whose value is this node's output with all occurrences of
+ * `other` removed.
+ * @param other the value to remove from this node's output.
+ * @return an expression whose value is this node's output with all occurrences of
+ * `other` removed.
+ */
+ LHExpression removeIfPresent(Serializable other);
+
+ /**
+ * Returns an expression whose value is this node's output with the index specified
+ * by `other` removed.
+ *
+ * Valid only for JSON_ARR expressions.
+ * @param index the index at which to insert the `other`.
+ * @return an expression whose value is this node's output with the `other` inserted
+ * at the specified `index`.
+ */
+ LHExpression removeIndex(int index);
+
+ /**
+ * Returns an expression whose value is this node's output with the index specified
+ * by `index` removed.
+ *
+ * Valid only for JSON_ARR expressions.
+ * @param index the index at which to remove the value.
+ * @return an expression whose value is this node's output with the value at the
+ * specified `index` removed.
+ */
+ LHExpression removeIndex(LHExpression index);
+
+ /**
+ * Returns an expression whose value is this node's output with the key specified
+ * by `key` removed.
+ *
+ * Valid only for JSON_OBJ expressions.
+ * @param key the key to remove from this node's output.
+ * @return an expression whose value is this node's output with the key specified
+ * by `key` removed.
+ */
+ LHExpression removeKey(Serializable key);
}
diff --git a/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/BuilderUtil.java b/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/BuilderUtil.java
index 6e6f8dbae..0ea6fb813 100644
--- a/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/BuilderUtil.java
+++ b/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/BuilderUtil.java
@@ -20,6 +20,9 @@ static VariableAssignment assignVariable(Object variable) {
builder.setJsonPath(wrv.jsonPath);
}
builder.setVariableName(wrv.name);
+ if (wrv.getTypeToCastTo() != null) {
+ builder.setTypeToCastTo(wrv.getTypeToCastTo());
+ }
} else if (NodeOutputImpl.class.isAssignableFrom(variable.getClass())) {
// We can use the new `VariableAssignment` feature: NodeOutputReference
NodeOutputImpl nodeReference = (NodeOutputImpl) variable;
@@ -43,6 +46,10 @@ static VariableAssignment assignVariable(Object variable) {
.setLhs(assignVariable(expr.getLhs()))
.setOperation(expr.getOperation())
.setRhs(assignVariable(expr.getRhs())));
+
+ if (expr.getTypeToCastTo() != null) {
+ builder.getExpressionBuilder().setTypeToCastTo(expr.getTypeToCastTo());
+ }
} else {
try {
VariableValue defVal = LHLibUtil.objToVarVal(variable);
diff --git a/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/LHExpressionImpl.java b/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/LHExpressionImpl.java
index 956a619ca..0c1576a89 100644
--- a/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/LHExpressionImpl.java
+++ b/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/LHExpressionImpl.java
@@ -1,9 +1,11 @@
package io.littlehorse.sdk.wfsdk.internal;
import io.littlehorse.sdk.common.proto.VariableMutationType;
+import io.littlehorse.sdk.common.proto.VariableType;
import io.littlehorse.sdk.wfsdk.LHExpression;
import java.io.Serializable;
import lombok.Getter;
+import lombok.Setter;
@Getter
public class LHExpressionImpl implements LHExpression {
@@ -12,6 +14,9 @@ public class LHExpressionImpl implements LHExpression {
private Serializable rhs;
private VariableMutationType operation;
+ @Setter
+ private VariableType typeToCastTo;
+
public LHExpressionImpl(Serializable lhs, VariableMutationType operation, Serializable rhs) {
this.lhs = lhs;
this.rhs = rhs;
@@ -62,4 +67,22 @@ public LHExpression removeIndex(LHExpression index) {
public LHExpression removeKey(Serializable key) {
return new LHExpressionImpl(this, VariableMutationType.REMOVE_KEY, key);
}
+
+ @Override
+ public LHExpression asStr() {
+ this.typeToCastTo = VariableType.STR;
+ return this;
+ }
+
+ @Override
+ public LHExpression asInt() {
+ this.typeToCastTo = VariableType.INT;
+ return this;
+ }
+
+ @Override
+ public LHExpression asDouble() {
+ this.typeToCastTo = VariableType.DOUBLE;
+ return this;
+ }
}
diff --git a/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/WfRunVariableImpl.java b/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/WfRunVariableImpl.java
index 48f6bd5ec..47ff24505 100644
--- a/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/WfRunVariableImpl.java
+++ b/sdk-java/src/main/java/io/littlehorse/sdk/wfsdk/internal/WfRunVariableImpl.java
@@ -31,6 +31,9 @@ class WfRunVariableImpl implements WfRunVariable {
private List jsonIndexes = new ArrayList<>();
private WfRunVariableAccessLevel accessLevel;
+ @Getter
+ private VariableType typeToCastTo;
+
public String jsonPath;
private final WorkflowThreadImpl parent;
@@ -224,6 +227,27 @@ public LHExpression removeKey(Serializable key) {
return new LHExpressionImpl(this, VariableMutationType.REMOVE_KEY, key);
}
+ @Override
+ public LHExpression asInt() {
+ WfRunVariableImpl result = new WfRunVariableImpl(name, typeOrDefaultVal, parent);
+ result.typeToCastTo = VariableType.INT;
+ return result;
+ }
+
+ @Override
+ public LHExpression asStr() {
+ WfRunVariableImpl result = new WfRunVariableImpl(name, typeOrDefaultVal, parent);
+ result.typeToCastTo = VariableType.STR;
+ return result;
+ }
+
+ @Override
+ public LHExpression asDouble() {
+ WfRunVariableImpl result = new WfRunVariableImpl(name, typeOrDefaultVal, parent);
+ result.typeToCastTo = VariableType.DOUBLE;
+ return result;
+ }
+
public ThreadVarDef getSpec() {
VariableDef.Builder varDef = VariableDef.newBuilder()
.setType(this.getType())
diff --git a/sdk-js/src/proto/common_wfspec.ts b/sdk-js/src/proto/common_wfspec.ts
index 5f890e2a0..8bbcf2036 100644
--- a/sdk-js/src/proto/common_wfspec.ts
+++ b/sdk-js/src/proto/common_wfspec.ts
@@ -221,7 +221,11 @@ export interface VariableAssignment {
| VariableAssignment_NodeOutputReference
| undefined;
/** Assign the value of an Expression. */
- expression?: VariableAssignment_Expression | undefined;
+ expression?:
+ | VariableAssignment_Expression
+ | undefined;
+ /** Allows casting this Variable Assignment to a specific type */
+ typeToCastTo?: VariableType | undefined;
}
/** A FormatString formats a template String with values from the WfRun. */
@@ -257,7 +261,11 @@ export interface VariableAssignment_Expression {
/** The operator in the expression. */
operation: VariableMutationType;
/** The right-hand-side of the expression. */
- rhs: VariableAssignment | undefined;
+ rhs:
+ | VariableAssignment
+ | undefined;
+ /** Allows casting this expression to a specific type */
+ typeToCastTo?: VariableType | undefined;
}
/**
@@ -493,6 +501,7 @@ function createBaseVariableAssignment(): VariableAssignment {
formatString: undefined,
nodeOutput: undefined,
expression: undefined,
+ typeToCastTo: undefined,
};
}
@@ -516,6 +525,9 @@ export const VariableAssignment = {
if (message.expression !== undefined) {
VariableAssignment_Expression.encode(message.expression, writer.uint32(50).fork()).ldelim();
}
+ if (message.typeToCastTo !== undefined) {
+ writer.uint32(56).int32(variableTypeToNumber(message.typeToCastTo));
+ }
return writer;
},
@@ -568,6 +580,13 @@ export const VariableAssignment = {
message.expression = VariableAssignment_Expression.decode(reader, reader.uint32());
continue;
+ case 7:
+ if (tag !== 56) {
+ break;
+ }
+
+ message.typeToCastTo = variableTypeFromJSON(reader.int32());
+ continue;
}
if ((tag & 7) === 4 || tag === 0) {
break;
@@ -596,6 +615,7 @@ export const VariableAssignment = {
message.expression = (object.expression !== undefined && object.expression !== null)
? VariableAssignment_Expression.fromPartial(object.expression)
: undefined;
+ message.typeToCastTo = object.typeToCastTo ?? undefined;
return message;
},
};
@@ -704,7 +724,7 @@ export const VariableAssignment_NodeOutputReference = {
};
function createBaseVariableAssignment_Expression(): VariableAssignment_Expression {
- return { lhs: undefined, operation: VariableMutationType.ASSIGN, rhs: undefined };
+ return { lhs: undefined, operation: VariableMutationType.ASSIGN, rhs: undefined, typeToCastTo: undefined };
}
export const VariableAssignment_Expression = {
@@ -718,6 +738,9 @@ export const VariableAssignment_Expression = {
if (message.rhs !== undefined) {
VariableAssignment.encode(message.rhs, writer.uint32(26).fork()).ldelim();
}
+ if (message.typeToCastTo !== undefined) {
+ writer.uint32(32).int32(variableTypeToNumber(message.typeToCastTo));
+ }
return writer;
},
@@ -749,6 +772,13 @@ export const VariableAssignment_Expression = {
message.rhs = VariableAssignment.decode(reader, reader.uint32());
continue;
+ case 4:
+ if (tag !== 32) {
+ break;
+ }
+
+ message.typeToCastTo = variableTypeFromJSON(reader.int32());
+ continue;
}
if ((tag & 7) === 4 || tag === 0) {
break;
@@ -770,6 +800,7 @@ export const VariableAssignment_Expression = {
message.rhs = (object.rhs !== undefined && object.rhs !== null)
? VariableAssignment.fromPartial(object.rhs)
: undefined;
+ message.typeToCastTo = object.typeToCastTo ?? undefined;
return message;
},
};
diff --git a/sdk-python/littlehorse/model/common_wfspec_pb2.py b/sdk-python/littlehorse/model/common_wfspec_pb2.py
index 35fdfd883..1e542bea9 100644
--- a/sdk-python/littlehorse/model/common_wfspec_pb2.py
+++ b/sdk-python/littlehorse/model/common_wfspec_pb2.py
@@ -16,7 +16,7 @@
import littlehorse.model.object_id_pb2 as object__id__pb2
-DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x13\x63ommon_wfspec.proto\x12\x0blittlehorse\x1a\x12\x63ommon_enums.proto\x1a\x0evariable.proto\x1a\x0fobject_id.proto\"\xa2\x05\n\x12VariableAssignment\x12\x16\n\tjson_path\x18\x01 \x01(\tH\x01\x88\x01\x01\x12\x17\n\rvariable_name\x18\x02 \x01(\tH\x00\x12\x33\n\rliteral_value\x18\x03 \x01(\x0b\x32\x1a.littlehorse.VariableValueH\x00\x12\x45\n\rformat_string\x18\x04 \x01(\x0b\x32,.littlehorse.VariableAssignment.FormatStringH\x00\x12J\n\x0bnode_output\x18\x05 \x01(\x0b\x32\x33.littlehorse.VariableAssignment.NodeOutputReferenceH\x00\x12@\n\nexpression\x18\x06 \x01(\x0b\x32*.littlehorse.VariableAssignment.ExpressionH\x00\x1an\n\x0c\x46ormatString\x12/\n\x06\x66ormat\x18\x01 \x01(\x0b\x32\x1f.littlehorse.VariableAssignment\x12-\n\x04\x61rgs\x18\x02 \x03(\x0b\x32\x1f.littlehorse.VariableAssignment\x1a(\n\x13NodeOutputReference\x12\x11\n\tnode_name\x18\x01 \x01(\t\x1a\x9e\x01\n\nExpression\x12,\n\x03lhs\x18\x01 \x01(\x0b\x32\x1f.littlehorse.VariableAssignment\x12\x34\n\toperation\x18\x02 \x01(\x0e\x32!.littlehorse.VariableMutationType\x12,\n\x03rhs\x18\x03 \x01(\x0b\x32\x1f.littlehorse.VariableAssignmentB\x08\n\x06sourceB\x0c\n\n_json_path\"\x84\x03\n\x10VariableMutation\x12\x10\n\x08lhs_name\x18\x01 \x01(\t\x12\x1a\n\rlhs_json_path\x18\x02 \x01(\tH\x01\x88\x01\x01\x12\x34\n\toperation\x18\x03 \x01(\x0e\x32!.littlehorse.VariableMutationType\x12\x39\n\x0erhs_assignment\x18\x04 \x01(\x0b\x32\x1f.littlehorse.VariableAssignmentH\x00\x12\x33\n\rliteral_value\x18\x05 \x01(\x0b\x32\x1a.littlehorse.VariableValueH\x00\x12\x45\n\x0bnode_output\x18\x06 \x01(\x0b\x32..littlehorse.VariableMutation.NodeOutputSourceH\x00\x1a\x36\n\x10NodeOutputSource\x12\x15\n\x08jsonpath\x18\n \x01(\tH\x00\x88\x01\x01\x42\x0b\n\t_jsonpathB\x0b\n\trhs_valueB\x10\n\x0e_lhs_json_path\"\xa4\x01\n\x0bVariableDef\x12\'\n\x04type\x18\x01 \x01(\x0e\x32\x19.littlehorse.VariableType\x12\x0c\n\x04name\x18\x02 \x01(\t\x12\x36\n\rdefault_value\x18\x03 \x01(\x0b\x32\x1a.littlehorse.VariableValueH\x00\x88\x01\x01\x12\x14\n\x0cmasked_value\x18\x04 \x01(\x08\x42\x10\n\x0e_default_value\"\xef\x04\n\x0fUTActionTrigger\x12\x34\n\x04task\x18\x01 \x01(\x0b\x32$.littlehorse.UTActionTrigger.UTATaskH\x00\x12\x38\n\x06\x63\x61ncel\x18\x02 \x01(\x0b\x32&.littlehorse.UTActionTrigger.UTACancelH\x00\x12<\n\x08reassign\x18\x03 \x01(\x0b\x32(.littlehorse.UTActionTrigger.UTAReassignH\x00\x12\x36\n\rdelay_seconds\x18\x05 \x01(\x0b\x32\x1f.littlehorse.VariableAssignment\x12\x31\n\x04hook\x18\x06 \x01(\x0e\x32#.littlehorse.UTActionTrigger.UTHook\x1a\x0b\n\tUTACancel\x1a`\n\x07UTATask\x12#\n\x04task\x18\x01 \x01(\x0b\x32\x15.littlehorse.TaskNode\x12\x30\n\tmutations\x18\x02 \x03(\x0b\x32\x1d.littlehorse.VariableMutation\x1a\x99\x01\n\x0bUTAReassign\x12\x35\n\x07user_id\x18\x01 \x01(\x0b\x32\x1f.littlehorse.VariableAssignmentH\x00\x88\x01\x01\x12\x38\n\nuser_group\x18\x02 \x01(\x0b\x32\x1f.littlehorse.VariableAssignmentH\x01\x88\x01\x01\x42\n\n\x08_user_idB\r\n\x0b_user_group\".\n\x06UTHook\x12\x0e\n\nON_ARRIVAL\x10\x00\x12\x14\n\x10ON_TASK_ASSIGNED\x10\x01\x42\x08\n\x06\x61\x63tion\"c\n\x1d\x45xponentialBackoffRetryPolicy\x12\x18\n\x10\x62\x61se_interval_ms\x18\x01 \x01(\x05\x12\x14\n\x0cmax_delay_ms\x18\x02 \x01(\x03\x12\x12\n\nmultiplier\x18\x03 \x01(\x02\"\xc9\x02\n\x08TaskNode\x12-\n\x0btask_def_id\x18\x01 \x01(\x0b\x32\x16.littlehorse.TaskDefIdH\x00\x12\x37\n\x0c\x64ynamic_task\x18\x06 \x01(\x0b\x32\x1f.littlehorse.VariableAssignmentH\x00\x12\x17\n\x0ftimeout_seconds\x18\x02 \x01(\x05\x12\x0f\n\x07retries\x18\x03 \x01(\x05\x12L\n\x13\x65xponential_backoff\x18\x05 \x01(\x0b\x32*.littlehorse.ExponentialBackoffRetryPolicyH\x01\x88\x01\x01\x12\x32\n\tvariables\x18\x04 \x03(\x0b\x32\x1f.littlehorse.VariableAssignmentB\x11\n\x0ftask_to_executeB\x16\n\x14_exponential_backoff*\x98\x01\n\x14VariableMutationType\x12\n\n\x06\x41SSIGN\x10\x00\x12\x07\n\x03\x41\x44\x44\x10\x01\x12\n\n\x06\x45XTEND\x10\x02\x12\x0c\n\x08SUBTRACT\x10\x03\x12\x0c\n\x08MULTIPLY\x10\x04\x12\n\n\x06\x44IVIDE\x10\x05\x12\x15\n\x11REMOVE_IF_PRESENT\x10\x06\x12\x10\n\x0cREMOVE_INDEX\x10\x07\x12\x0e\n\nREMOVE_KEY\x10\x08*\x84\x01\n\nComparator\x12\r\n\tLESS_THAN\x10\x00\x12\x10\n\x0cGREATER_THAN\x10\x01\x12\x10\n\x0cLESS_THAN_EQ\x10\x02\x12\x13\n\x0fGREATER_THAN_EQ\x10\x03\x12\n\n\x06\x45QUALS\x10\x04\x12\x0e\n\nNOT_EQUALS\x10\x05\x12\x06\n\x02IN\x10\x06\x12\n\n\x06NOT_IN\x10\x07\x42I\n\x1fio.littlehorse.sdk.common.protoP\x01Z\t.;lhproto\xaa\x02\x18LittleHorse.Common.Protob\x06proto3')
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x13\x63ommon_wfspec.proto\x12\x0blittlehorse\x1a\x12\x63ommon_enums.proto\x1a\x0evariable.proto\x1a\x0fobject_id.proto\"\xbc\x06\n\x12VariableAssignment\x12\x16\n\tjson_path\x18\x01 \x01(\tH\x01\x88\x01\x01\x12\x17\n\rvariable_name\x18\x02 \x01(\tH\x00\x12\x33\n\rliteral_value\x18\x03 \x01(\x0b\x32\x1a.littlehorse.VariableValueH\x00\x12\x45\n\rformat_string\x18\x04 \x01(\x0b\x32,.littlehorse.VariableAssignment.FormatStringH\x00\x12J\n\x0bnode_output\x18\x05 \x01(\x0b\x32\x33.littlehorse.VariableAssignment.NodeOutputReferenceH\x00\x12@\n\nexpression\x18\x06 \x01(\x0b\x32*.littlehorse.VariableAssignment.ExpressionH\x00\x12\x37\n\x0ftype_to_cast_to\x18\x07 \x01(\x0e\x32\x19.littlehorse.VariableTypeH\x02\x88\x01\x01\x1an\n\x0c\x46ormatString\x12/\n\x06\x66ormat\x18\x01 \x01(\x0b\x32\x1f.littlehorse.VariableAssignment\x12-\n\x04\x61rgs\x18\x02 \x03(\x0b\x32\x1f.littlehorse.VariableAssignment\x1a(\n\x13NodeOutputReference\x12\x11\n\tnode_name\x18\x01 \x01(\t\x1a\xeb\x01\n\nExpression\x12,\n\x03lhs\x18\x01 \x01(\x0b\x32\x1f.littlehorse.VariableAssignment\x12\x34\n\toperation\x18\x02 \x01(\x0e\x32!.littlehorse.VariableMutationType\x12,\n\x03rhs\x18\x03 \x01(\x0b\x32\x1f.littlehorse.VariableAssignment\x12\x37\n\x0ftype_to_cast_to\x18\x04 \x01(\x0e\x32\x19.littlehorse.VariableTypeH\x00\x88\x01\x01\x42\x12\n\x10_type_to_cast_toB\x08\n\x06sourceB\x0c\n\n_json_pathB\x12\n\x10_type_to_cast_to\"\x84\x03\n\x10VariableMutation\x12\x10\n\x08lhs_name\x18\x01 \x01(\t\x12\x1a\n\rlhs_json_path\x18\x02 \x01(\tH\x01\x88\x01\x01\x12\x34\n\toperation\x18\x03 \x01(\x0e\x32!.littlehorse.VariableMutationType\x12\x39\n\x0erhs_assignment\x18\x04 \x01(\x0b\x32\x1f.littlehorse.VariableAssignmentH\x00\x12\x33\n\rliteral_value\x18\x05 \x01(\x0b\x32\x1a.littlehorse.VariableValueH\x00\x12\x45\n\x0bnode_output\x18\x06 \x01(\x0b\x32..littlehorse.VariableMutation.NodeOutputSourceH\x00\x1a\x36\n\x10NodeOutputSource\x12\x15\n\x08jsonpath\x18\n \x01(\tH\x00\x88\x01\x01\x42\x0b\n\t_jsonpathB\x0b\n\trhs_valueB\x10\n\x0e_lhs_json_path\"\xa4\x01\n\x0bVariableDef\x12\'\n\x04type\x18\x01 \x01(\x0e\x32\x19.littlehorse.VariableType\x12\x0c\n\x04name\x18\x02 \x01(\t\x12\x36\n\rdefault_value\x18\x03 \x01(\x0b\x32\x1a.littlehorse.VariableValueH\x00\x88\x01\x01\x12\x14\n\x0cmasked_value\x18\x04 \x01(\x08\x42\x10\n\x0e_default_value\"\xef\x04\n\x0fUTActionTrigger\x12\x34\n\x04task\x18\x01 \x01(\x0b\x32$.littlehorse.UTActionTrigger.UTATaskH\x00\x12\x38\n\x06\x63\x61ncel\x18\x02 \x01(\x0b\x32&.littlehorse.UTActionTrigger.UTACancelH\x00\x12<\n\x08reassign\x18\x03 \x01(\x0b\x32(.littlehorse.UTActionTrigger.UTAReassignH\x00\x12\x36\n\rdelay_seconds\x18\x05 \x01(\x0b\x32\x1f.littlehorse.VariableAssignment\x12\x31\n\x04hook\x18\x06 \x01(\x0e\x32#.littlehorse.UTActionTrigger.UTHook\x1a\x0b\n\tUTACancel\x1a`\n\x07UTATask\x12#\n\x04task\x18\x01 \x01(\x0b\x32\x15.littlehorse.TaskNode\x12\x30\n\tmutations\x18\x02 \x03(\x0b\x32\x1d.littlehorse.VariableMutation\x1a\x99\x01\n\x0bUTAReassign\x12\x35\n\x07user_id\x18\x01 \x01(\x0b\x32\x1f.littlehorse.VariableAssignmentH\x00\x88\x01\x01\x12\x38\n\nuser_group\x18\x02 \x01(\x0b\x32\x1f.littlehorse.VariableAssignmentH\x01\x88\x01\x01\x42\n\n\x08_user_idB\r\n\x0b_user_group\".\n\x06UTHook\x12\x0e\n\nON_ARRIVAL\x10\x00\x12\x14\n\x10ON_TASK_ASSIGNED\x10\x01\x42\x08\n\x06\x61\x63tion\"c\n\x1d\x45xponentialBackoffRetryPolicy\x12\x18\n\x10\x62\x61se_interval_ms\x18\x01 \x01(\x05\x12\x14\n\x0cmax_delay_ms\x18\x02 \x01(\x03\x12\x12\n\nmultiplier\x18\x03 \x01(\x02\"\xc9\x02\n\x08TaskNode\x12-\n\x0btask_def_id\x18\x01 \x01(\x0b\x32\x16.littlehorse.TaskDefIdH\x00\x12\x37\n\x0c\x64ynamic_task\x18\x06 \x01(\x0b\x32\x1f.littlehorse.VariableAssignmentH\x00\x12\x17\n\x0ftimeout_seconds\x18\x02 \x01(\x05\x12\x0f\n\x07retries\x18\x03 \x01(\x05\x12L\n\x13\x65xponential_backoff\x18\x05 \x01(\x0b\x32*.littlehorse.ExponentialBackoffRetryPolicyH\x01\x88\x01\x01\x12\x32\n\tvariables\x18\x04 \x03(\x0b\x32\x1f.littlehorse.VariableAssignmentB\x11\n\x0ftask_to_executeB\x16\n\x14_exponential_backoff*\x98\x01\n\x14VariableMutationType\x12\n\n\x06\x41SSIGN\x10\x00\x12\x07\n\x03\x41\x44\x44\x10\x01\x12\n\n\x06\x45XTEND\x10\x02\x12\x0c\n\x08SUBTRACT\x10\x03\x12\x0c\n\x08MULTIPLY\x10\x04\x12\n\n\x06\x44IVIDE\x10\x05\x12\x15\n\x11REMOVE_IF_PRESENT\x10\x06\x12\x10\n\x0cREMOVE_INDEX\x10\x07\x12\x0e\n\nREMOVE_KEY\x10\x08*\x84\x01\n\nComparator\x12\r\n\tLESS_THAN\x10\x00\x12\x10\n\x0cGREATER_THAN\x10\x01\x12\x10\n\x0cLESS_THAN_EQ\x10\x02\x12\x13\n\x0fGREATER_THAN_EQ\x10\x03\x12\n\n\x06\x45QUALS\x10\x04\x12\x0e\n\nNOT_EQUALS\x10\x05\x12\x06\n\x02IN\x10\x06\x12\n\n\x06NOT_IN\x10\x07\x42I\n\x1fio.littlehorse.sdk.common.protoP\x01Z\t.;lhproto\xaa\x02\x18LittleHorse.Common.Protob\x06proto3')
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
@@ -25,36 +25,36 @@
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'\n\037io.littlehorse.sdk.common.protoP\001Z\t.;lhproto\252\002\030LittleHorse.Common.Proto'
- _globals['_VARIABLEMUTATIONTYPE']._serialized_start=2384
- _globals['_VARIABLEMUTATIONTYPE']._serialized_end=2536
- _globals['_COMPARATOR']._serialized_start=2539
- _globals['_COMPARATOR']._serialized_end=2671
+ _globals['_VARIABLEMUTATIONTYPE']._serialized_start=2538
+ _globals['_VARIABLEMUTATIONTYPE']._serialized_end=2690
+ _globals['_COMPARATOR']._serialized_start=2693
+ _globals['_COMPARATOR']._serialized_end=2825
_globals['_VARIABLEASSIGNMENT']._serialized_start=90
- _globals['_VARIABLEASSIGNMENT']._serialized_end=764
- _globals['_VARIABLEASSIGNMENT_FORMATSTRING']._serialized_start=427
- _globals['_VARIABLEASSIGNMENT_FORMATSTRING']._serialized_end=537
- _globals['_VARIABLEASSIGNMENT_NODEOUTPUTREFERENCE']._serialized_start=539
- _globals['_VARIABLEASSIGNMENT_NODEOUTPUTREFERENCE']._serialized_end=579
- _globals['_VARIABLEASSIGNMENT_EXPRESSION']._serialized_start=582
- _globals['_VARIABLEASSIGNMENT_EXPRESSION']._serialized_end=740
- _globals['_VARIABLEMUTATION']._serialized_start=767
- _globals['_VARIABLEMUTATION']._serialized_end=1155
- _globals['_VARIABLEMUTATION_NODEOUTPUTSOURCE']._serialized_start=1070
- _globals['_VARIABLEMUTATION_NODEOUTPUTSOURCE']._serialized_end=1124
- _globals['_VARIABLEDEF']._serialized_start=1158
- _globals['_VARIABLEDEF']._serialized_end=1322
- _globals['_UTACTIONTRIGGER']._serialized_start=1325
- _globals['_UTACTIONTRIGGER']._serialized_end=1948
- _globals['_UTACTIONTRIGGER_UTACANCEL']._serialized_start=1625
- _globals['_UTACTIONTRIGGER_UTACANCEL']._serialized_end=1636
- _globals['_UTACTIONTRIGGER_UTATASK']._serialized_start=1638
- _globals['_UTACTIONTRIGGER_UTATASK']._serialized_end=1734
- _globals['_UTACTIONTRIGGER_UTAREASSIGN']._serialized_start=1737
- _globals['_UTACTIONTRIGGER_UTAREASSIGN']._serialized_end=1890
- _globals['_UTACTIONTRIGGER_UTHOOK']._serialized_start=1892
- _globals['_UTACTIONTRIGGER_UTHOOK']._serialized_end=1938
- _globals['_EXPONENTIALBACKOFFRETRYPOLICY']._serialized_start=1950
- _globals['_EXPONENTIALBACKOFFRETRYPOLICY']._serialized_end=2049
- _globals['_TASKNODE']._serialized_start=2052
- _globals['_TASKNODE']._serialized_end=2381
+ _globals['_VARIABLEASSIGNMENT']._serialized_end=918
+ _globals['_VARIABLEASSIGNMENT_FORMATSTRING']._serialized_start=484
+ _globals['_VARIABLEASSIGNMENT_FORMATSTRING']._serialized_end=594
+ _globals['_VARIABLEASSIGNMENT_NODEOUTPUTREFERENCE']._serialized_start=596
+ _globals['_VARIABLEASSIGNMENT_NODEOUTPUTREFERENCE']._serialized_end=636
+ _globals['_VARIABLEASSIGNMENT_EXPRESSION']._serialized_start=639
+ _globals['_VARIABLEASSIGNMENT_EXPRESSION']._serialized_end=874
+ _globals['_VARIABLEMUTATION']._serialized_start=921
+ _globals['_VARIABLEMUTATION']._serialized_end=1309
+ _globals['_VARIABLEMUTATION_NODEOUTPUTSOURCE']._serialized_start=1224
+ _globals['_VARIABLEMUTATION_NODEOUTPUTSOURCE']._serialized_end=1278
+ _globals['_VARIABLEDEF']._serialized_start=1312
+ _globals['_VARIABLEDEF']._serialized_end=1476
+ _globals['_UTACTIONTRIGGER']._serialized_start=1479
+ _globals['_UTACTIONTRIGGER']._serialized_end=2102
+ _globals['_UTACTIONTRIGGER_UTACANCEL']._serialized_start=1779
+ _globals['_UTACTIONTRIGGER_UTACANCEL']._serialized_end=1790
+ _globals['_UTACTIONTRIGGER_UTATASK']._serialized_start=1792
+ _globals['_UTACTIONTRIGGER_UTATASK']._serialized_end=1888
+ _globals['_UTACTIONTRIGGER_UTAREASSIGN']._serialized_start=1891
+ _globals['_UTACTIONTRIGGER_UTAREASSIGN']._serialized_end=2044
+ _globals['_UTACTIONTRIGGER_UTHOOK']._serialized_start=2046
+ _globals['_UTACTIONTRIGGER_UTHOOK']._serialized_end=2092
+ _globals['_EXPONENTIALBACKOFFRETRYPOLICY']._serialized_start=2104
+ _globals['_EXPONENTIALBACKOFFRETRYPOLICY']._serialized_end=2203
+ _globals['_TASKNODE']._serialized_start=2206
+ _globals['_TASKNODE']._serialized_end=2535
# @@protoc_insertion_point(module_scope)
diff --git a/sdk-python/littlehorse/model/common_wfspec_pb2.pyi b/sdk-python/littlehorse/model/common_wfspec_pb2.pyi
index 6462238a7..799d19cda 100644
--- a/sdk-python/littlehorse/model/common_wfspec_pb2.pyi
+++ b/sdk-python/littlehorse/model/common_wfspec_pb2.pyi
@@ -50,7 +50,7 @@ IN: Comparator
NOT_IN: Comparator
class VariableAssignment(_message.Message):
- __slots__ = ["json_path", "variable_name", "literal_value", "format_string", "node_output", "expression"]
+ __slots__ = ["json_path", "variable_name", "literal_value", "format_string", "node_output", "expression", "type_to_cast_to"]
class FormatString(_message.Message):
__slots__ = ["format", "args"]
FORMAT_FIELD_NUMBER: _ClassVar[int]
@@ -64,27 +64,31 @@ class VariableAssignment(_message.Message):
node_name: str
def __init__(self, node_name: _Optional[str] = ...) -> None: ...
class Expression(_message.Message):
- __slots__ = ["lhs", "operation", "rhs"]
+ __slots__ = ["lhs", "operation", "rhs", "type_to_cast_to"]
LHS_FIELD_NUMBER: _ClassVar[int]
OPERATION_FIELD_NUMBER: _ClassVar[int]
RHS_FIELD_NUMBER: _ClassVar[int]
+ TYPE_TO_CAST_TO_FIELD_NUMBER: _ClassVar[int]
lhs: VariableAssignment
operation: VariableMutationType
rhs: VariableAssignment
- def __init__(self, lhs: _Optional[_Union[VariableAssignment, _Mapping]] = ..., operation: _Optional[_Union[VariableMutationType, str]] = ..., rhs: _Optional[_Union[VariableAssignment, _Mapping]] = ...) -> None: ...
+ type_to_cast_to: _common_enums_pb2.VariableType
+ def __init__(self, lhs: _Optional[_Union[VariableAssignment, _Mapping]] = ..., operation: _Optional[_Union[VariableMutationType, str]] = ..., rhs: _Optional[_Union[VariableAssignment, _Mapping]] = ..., type_to_cast_to: _Optional[_Union[_common_enums_pb2.VariableType, str]] = ...) -> None: ...
JSON_PATH_FIELD_NUMBER: _ClassVar[int]
VARIABLE_NAME_FIELD_NUMBER: _ClassVar[int]
LITERAL_VALUE_FIELD_NUMBER: _ClassVar[int]
FORMAT_STRING_FIELD_NUMBER: _ClassVar[int]
NODE_OUTPUT_FIELD_NUMBER: _ClassVar[int]
EXPRESSION_FIELD_NUMBER: _ClassVar[int]
+ TYPE_TO_CAST_TO_FIELD_NUMBER: _ClassVar[int]
json_path: str
variable_name: str
literal_value: _variable_pb2.VariableValue
format_string: VariableAssignment.FormatString
node_output: VariableAssignment.NodeOutputReference
expression: VariableAssignment.Expression
- def __init__(self, json_path: _Optional[str] = ..., variable_name: _Optional[str] = ..., literal_value: _Optional[_Union[_variable_pb2.VariableValue, _Mapping]] = ..., format_string: _Optional[_Union[VariableAssignment.FormatString, _Mapping]] = ..., node_output: _Optional[_Union[VariableAssignment.NodeOutputReference, _Mapping]] = ..., expression: _Optional[_Union[VariableAssignment.Expression, _Mapping]] = ...) -> None: ...
+ type_to_cast_to: _common_enums_pb2.VariableType
+ def __init__(self, json_path: _Optional[str] = ..., variable_name: _Optional[str] = ..., literal_value: _Optional[_Union[_variable_pb2.VariableValue, _Mapping]] = ..., format_string: _Optional[_Union[VariableAssignment.FormatString, _Mapping]] = ..., node_output: _Optional[_Union[VariableAssignment.NodeOutputReference, _Mapping]] = ..., expression: _Optional[_Union[VariableAssignment.Expression, _Mapping]] = ..., type_to_cast_to: _Optional[_Union[_common_enums_pb2.VariableType, str]] = ...) -> None: ...
class VariableMutation(_message.Message):
__slots__ = ["lhs_name", "lhs_json_path", "operation", "rhs_assignment", "literal_value", "node_output"]
diff --git a/server/src/main/java/io/littlehorse/common/model/getable/core/wfrun/ThreadRunModel.java b/server/src/main/java/io/littlehorse/common/model/getable/core/wfrun/ThreadRunModel.java
index ef2637e66..a01cc1446 100644
--- a/server/src/main/java/io/littlehorse/common/model/getable/core/wfrun/ThreadRunModel.java
+++ b/server/src/main/java/io/littlehorse/common/model/getable/core/wfrun/ThreadRunModel.java
@@ -761,77 +761,77 @@ public VariableValueModel assignVariable(VariableAssignmentModel assn) throws LH
return assignVariable(assn, new HashMap<>());
}
- public VariableValueModel assignVariable(VariableAssignmentModel assn, Map txnCache)
- throws LHVarSubError {
- VariableValueModel val = null;
- switch (assn.getRhsSourceType()) {
- case LITERAL_VALUE:
- val = assn.getRhsLiteralValue();
- break;
- case VARIABLE_NAME:
- if (txnCache.containsKey(assn.getVariableName())) {
- val = txnCache.get(assn.getVariableName());
- } else {
- val = getVariable(assn.getVariableName()).getValue();
- }
-
- if (val == null) {
- throw new LHVarSubError(null, "Variable " + assn.getVariableName() + " not in scope!");
- }
-
- break;
- case FORMAT_STRING:
- // first, assign the format string
- VariableValueModel formatStringVarVal =
- assignVariable(assn.getFormatString().getFormat(), txnCache);
- if (formatStringVarVal.getType() != VariableType.STR) {
- throw new LHVarSubError(
- null, "Format String template isn't a STR; it's a " + formatStringVarVal.getType());
- }
-
- List