Skip to content

Commit 09412fd

Browse files
StephanEwenigalshilman
authored andcommitted
Set retention to one week for now
1 parent b67fcac commit 09412fd

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/workflows/workflow_wrapper_service.ts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,8 @@ import * as restate from "../public_api";
1313
import * as wf from "./workflow";
1414
import * as wss from "./workflow_state_service";
1515

16+
const DEFAULT_RETENTION_PERIOD = 7 * 24 * 60 * 60 * 1000; // 1 week
17+
1618
// ----------------------------------------------------------------------------
1719
// Workflow Context Implementations
1820
// ----------------------------------------------------------------------------
@@ -166,7 +168,7 @@ class ExclusiveContextImpl extends SharedContextImpl implements wf.WfContext {
166168
}
167169

168170
// ----------------------------------------------------------------------------
169-
171+
// the service that wraps the workflow methods
170172
// ----------------------------------------------------------------------------
171173

172174
export function createWrapperService<R, T, M>(
@@ -216,7 +218,7 @@ export function createWrapperService<R, T, M>(
216218
throw err;
217219
} finally {
218220
ctx
219-
.sendDelayed(stateServiceApi, 2 * 60 * 1000)
221+
.sendDelayed(stateServiceApi, DEFAULT_RETENTION_PERIOD)
220222
.dispose(request.workflowId);
221223
}
222224
},

0 commit comments

Comments
 (0)