Skip to content

Commit aa5b058

Browse files
committed
fix: more memory related changes
1 parent a8bdea6 commit aa5b058

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

shared.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17988,7 +17988,7 @@ func compressExecution(ctx context.Context, workflowExecution WorkflowExecution,
1798817988
log.Printf("[DEBUG] Execution size: %d for %s", len(jsonString), workflowExecution.ExecutionId)
1798917989
}
1799017990

17991-
if len(jsonString) > 1000000 {
17991+
if len(jsonString) > 10000000 {
1799217992
log.Printf("[WARNING][%s] Execution size is still too large (%d) when running %s!", workflowExecution.ExecutionId, len(jsonString), saveLocationInfo)
1799317993

1799417994
for resultIndex, result := range workflowExecution.Results {
@@ -17997,9 +17997,9 @@ func compressExecution(ctx context.Context, workflowExecution WorkflowExecution,
1799717997
// log.Printf("[DEBUG] Result Size (%s - action: %d). Value size: %d", result.Action.Label, len(actionData), len(result.Result))
1799817998
}
1799917999

18000-
if len(actionData) > 10000 {
18000+
if len(actionData) > 1000000 {
1800118001
for paramIndex, param := range result.Action.Parameters {
18002-
if len(param.Value) > 10000 {
18002+
if len(param.Value) > 1000000 {
1800318003
// log.Printf("[WARNING][%s] Parameter %s in action %s is too large (%d). Removing value.", workflowExecution.ExecutionId, param.Name, result.Action.Label, len(param.Value))
1800418004
workflowExecution.Results[resultIndex].Action.Parameters[paramIndex].Value = "Size too large. Removed."
1800518005
}

0 commit comments

Comments
 (0)