diff --git a/packages/compute-worker/src/operations/reconciliation.ts b/packages/compute-worker/src/operations/reconciliation.ts
index df8dc9e..921587f 100644
--- a/packages/compute-worker/src/operations/reconciliation.ts
+++ b/packages/compute-worker/src/operations/reconciliation.ts
@@ -55,8 +55,8 @@ export function createOperationReconciler(input: {
     recoveryPromise = (async () => {
       const recoveredStates = await recoverOrphanedOperations({
         operationStateStore: {
-          getOpStateRecord: input.stateStore.getOpStateRecord!,
-          listOpStates: input.stateStore.listOpStates!,
+          getOpStateRecord: (opId) => input.stateStore.getOpStateRecord!(opId),
+          listOpStates: () => input.stateStore.listOpStates!(),
         },
         orchestrator: {
           markFailedIfUnchanged: async (request) => {