refactor(sdk): remove unused activeOperationsTracker dead code

packages/aws-durable-execution-sdk-js/src/context/execution-context/execution-context.test.ts

@@ -138,7 +138,7 @@ describe("initializeExecutionContext", () => {
         durableExecutionClient: mockDurableExecutionClient,
         _stepData: {},
         terminationManager: expect.any(Object),
-        activeOperationsTracker: expect.any(Object),
+
         durableExecutionArn: mockDurableExecutionArn,
         pendingCompletions: expect.any(Set),
         getStepData: expect.any(Function),

packages/aws-durable-execution-sdk-js/src/context/execution-context/execution-context.ts

@@ -8,7 +8,7 @@ import {
 import { log } from "../../utils/logger/logger";
 import { getStepData as getStepDataUtil } from "../../utils/step-id-utils/step-id-utils";
 import { createDefaultLogger } from "../../utils/logger/default-logger";
-import { ActiveOperationsTracker } from "../../utils/termination-helper/active-operations-tracker";
+
 import { Context } from "aws-lambda";
 import { DurableExecutionApiClient } from "../../durable-execution-api-client/durable-execution-api-client";
 import { DurableExecutionInvocationInputWithClient } from "../../utils/durable-execution-invocation-input/durable-execution-invocation-input";
@@ -84,7 +84,7 @@ export const initializeExecutionContext = async (
       durableExecutionClient,
       _stepData: stepData,
       terminationManager: new TerminationManager(),
-      activeOperationsTracker: new ActiveOperationsTracker(),
+
       durableExecutionArn,
       pendingCompletions: new Set<string>(),
       getStepData(stepId: string): Operation | undefined {

packages/aws-durable-execution-sdk-js/src/termination-manager/termination-manager-checkpoint.test.ts

@@ -18,7 +18,6 @@ const createCheckpoint = (
     {},
     context.durableExecutionClient,
     context.terminationManager,
-    undefined,
     token,
     emitter,
     logger,

packages/aws-durable-execution-sdk-js/src/testing/create-test-checkpoint-manager.ts

@@ -13,7 +13,6 @@ export const createTestCheckpointManager = (
     context._stepData,
     context.durableExecutionClient,
     context.terminationManager,
-    context.activeOperationsTracker,
     checkpointToken,
     emitter,
     logger,

packages/aws-durable-execution-sdk-js/src/testing/create-test-durable-context.ts

@@ -82,7 +82,6 @@ export function createTestDurableContext(options?: {
     },
     requestId: "mock-request-id",
     tenantId: undefined,
-    activeOperationsTracker: undefined,
   };
 
   const mockLambdaContext: Context = {

packages/aws-durable-execution-sdk-js/src/testing/mock-checkpoint-manager.ts

@@ -20,7 +20,6 @@ export class MockCheckpointManager extends CheckpointManager {
       {},
       {} as DurableExecutionClient,
       {} as TerminationManager,
-      undefined,
       "mock-token",
       {} as EventEmitter,
       {} as DurableLogger,

packages/aws-durable-execution-sdk-js/src/types/core.ts

@@ -1,7 +1,6 @@
 import { TerminationManager } from "../termination-manager/termination-manager";
 import { DurableExecutionClient } from "./durable-execution";
 import { ErrorObject, Operation } from "@aws-sdk/client-lambda";
-import { ActiveOperationsTracker } from "../utils/termination-helper/active-operations-tracker";
 
 /**
  * @internal
@@ -323,7 +322,7 @@ export interface ExecutionContext {
   _stepData: Record<string, Operation>; // Private, use getStepData() instead
   terminationManager: TerminationManager;
   durableExecutionArn: string;
-  activeOperationsTracker?: ActiveOperationsTracker;
+
   requestId: string;
   tenantId: string | undefined;
   pendingCompletions: Set<string>; // Track stepIds with pending SUCCEED/FAIL

packages/aws-durable-execution-sdk-js/src/utils/checkpoint/checkpoint-central-termination.test.ts

@@ -33,7 +33,6 @@ describe("CheckpointManager - Centralized Termination", () => {
       {},
       mockClient,
       mockTerminationManager,
-      undefined,
       "test-token",
       mockStepDataEmitter,
       {} as any,

packages/aws-durable-execution-sdk-js/src/utils/checkpoint/checkpoint-integration.test.ts

@@ -52,7 +52,6 @@ describe("Checkpoint Integration Tests", () => {
       {},
       mockState,
       { terminate: jest.fn() } as any,
-      undefined,
       TEST_CONSTANTS.CHECKPOINT_TOKEN,
       mockEmitter,
       mockLogger,
@@ -90,7 +89,6 @@ describe("Checkpoint Integration Tests", () => {
       {},
       mockState,
       { terminate: jest.fn() } as any,
-      undefined,
       TEST_CONSTANTS.CHECKPOINT_TOKEN,
       mockEmitter,
       mockLogger,
@@ -177,7 +175,6 @@ describe("Checkpoint Integration Tests", () => {
       {},
       mockState,
       { terminate: jest.fn() } as any,
-      undefined,
       TEST_CONSTANTS.CHECKPOINT_TOKEN,
       mockEmitter,
       mockLogger,
@@ -217,7 +214,6 @@ describe("Checkpoint Integration Tests", () => {
       {},
       mockState,
       { terminate: jest.fn() } as any,
-      undefined,
       TEST_CONSTANTS.CHECKPOINT_TOKEN,
       mockEmitter,
       mockLogger,
@@ -270,7 +266,6 @@ describe("Checkpoint Integration Tests", () => {
       {},
       mockState,
       { terminate: jest.fn() } as any,
-      undefined,
       TEST_CONSTANTS.CHECKPOINT_TOKEN,
       mockEmitter,
       mockLogger,
@@ -284,7 +279,6 @@ describe("Checkpoint Integration Tests", () => {
       {},
       mockState2,
       { terminate: jest.fn() } as any,
-      undefined,
       TEST_CONSTANTS.CHECKPOINT_TOKEN,
       mockEmitter,
       mockLogger,

packages/aws-durable-execution-sdk-js/src/utils/checkpoint/checkpoint-manager.ts

@@ -32,11 +32,6 @@ interface QueuedCheckpoint {
   reject: (error: Error) => void;
 }
 
-interface ActiveOperationsTracker {
-  increment(): void;
-  decrement(): void;
-}
-
 export class CheckpointManager implements Checkpoint {
   private queue: QueuedCheckpoint[] = [];
   private isProcessing = false;
@@ -64,7 +59,6 @@ export class CheckpointManager implements Checkpoint {
     private stepData: Record<string, Operation>,
     private storage: DurableExecutionClient,
     private terminationManager: TerminationManager,
-    private activeOperationsTracker: ActiveOperationsTracker | undefined,
     initialTaskToken: string,
     private stepDataEmitter: EventEmitter,
     private logger: DurableLogger,
@@ -154,10 +148,6 @@ export class CheckpointManager implements Checkpoint {
       return new Promise(() => {}); // Never resolves during termination
     }
 
-    if (this.activeOperationsTracker) {
-      this.activeOperationsTracker.increment();
-    }
-
     return new Promise<void>((resolve, reject) => {
       if (
         data.Action === OperationAction.SUCCEED ||
@@ -170,15 +160,9 @@ export class CheckpointManager implements Checkpoint {
         stepId,
         data,
         resolve: () => {
-          if (this.activeOperationsTracker) {
-            this.activeOperationsTracker.decrement();
-          }
           resolve();
         },
         reject: (error: Error) => {
-          if (this.activeOperationsTracker) {
-            this.activeOperationsTracker.decrement();
-          }
           reject(error);
         },
       };

packages/aws-durable-execution-sdk-js/src/utils/checkpoint/checkpoint-queue-completion.test.ts

@@ -26,7 +26,6 @@ describe("CheckpointManager Queue Completion", () => {
       mockContext._stepData,
       mockContext.state,
       mockTerminationManager,
-      undefined,
       "test-token",
       mockEmitter,
       mockLogger,

packages/aws-durable-execution-sdk-js/src/utils/checkpoint/checkpoint.test.ts

@@ -30,7 +30,6 @@ const createCheckpoint = (
     context._stepData,
     context.durableExecutionClient,
     context.terminationManager,
-    undefined,
     token,
     emitter,
     logger,