Skip to content

Commit b38fc72

Browse files
committed
feat: Add internal semaphore for available task slots in executor process
1 parent 6a95a52 commit b38fc72

2 files changed

Lines changed: 2 additions & 1 deletion

File tree

ballista/executor/src/executor_process.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -434,6 +434,7 @@ pub async fn start_executor_process(
434434
default_codec,
435435
None,
436436
None, // poll_now_notify: not used in standalone executor
437+
None, // available_task_slots: use internal semaphore
437438
)));
438439
}
439440
};

ballista/executor/src/standalone.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -144,7 +144,7 @@ pub async fn new_standalone_executor_from_builder(
144144
);
145145

146146
tokio::spawn(execution_loop::poll_loop(
147-
scheduler, executor, codec, None, None,
147+
scheduler, executor, codec, None, None, None,
148148
));
149149
Ok(())
150150
}

0 commit comments

Comments
 (0)