ClientAwaitedAction now uses a channel to notify drops happened

Instead of using Weak references and custom spawns, we now use a channel to notify receivers that cleanups are needed.
TraceMachina · Jul 10, 2024 · 08073c9 · 08073c9
1 parent d58543b
commit 08073c9
Show file tree

Hide file tree

Showing 2 changed files with 139 additions and 147 deletions.
diff --git a/nativelink-scheduler/src/scheduler_state/awaited_action.rs b/nativelink-scheduler/src/scheduler_state/awaited_action.rs
@@ -68,7 +68,7 @@ pub struct AwaitedAction {
     action_info: Arc<ActionInfo>,
 
     // The unique identifier of the operation.
-    // TODO(operation_id should be stored here).
+    // TODO!(operation_id should be stored here).
     // operation_id: OperationId,
     /// The data that is used to sort the action in the queue.
     /// The first item in the tuple is the current priority,