diff --git a/nativelink-scheduler/src/operation_state_manager.rs b/nativelink-scheduler/src/operation_state_manager.rs index 16dbd38ca..aedac4775 100644 --- a/nativelink-scheduler/src/operation_state_manager.rs +++ b/nativelink-scheduler/src/operation_state_manager.rs @@ -144,9 +144,4 @@ pub trait MatchingEngineStateManager: Sync + Send + 'static { operation_id: &OperationId, worker_id_or_reason_for_unsassign: Result<&WorkerId, Error>, ) -> Result<(), Error>; - - /// Remove an operation from the state manager. - /// It is important to use this function to remove operations - /// that are no longer needed to prevent memory leaks. - async fn remove_operation(&self, operation_id: OperationId) -> Result<(), Error>; } diff --git a/nativelink-scheduler/src/scheduler_state/state_manager.rs b/nativelink-scheduler/src/scheduler_state/state_manager.rs index ac4d32863..5033d86be 100644 --- a/nativelink-scheduler/src/scheduler_state/state_manager.rs +++ b/nativelink-scheduler/src/scheduler_state/state_manager.rs @@ -999,8 +999,4 @@ impl MatchingEngineStateManager for StateManager { }; inner.inner_update_operation(operation_id, maybe_worker_id, stage_result) } - - async fn remove_operation(&self, _operation_id: OperationId) -> Result<(), Error> { - todo!() - } }