We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7b3fc82 commit c888180Copy full SHA for c888180
compute/src/workers/workflow.rs
@@ -105,7 +105,7 @@ impl WorkflowsWorker {
105
// get tasks in batch from the channel, we enter the loop if:
106
// (1) there are no tasks, or,
107
// (2) there are tasks less than the batch size and the channel is not empty
108
- while tasks.len() == 0 || (tasks.len() < batch_size && !self.workflow_rx.is_empty()) {
+ while tasks.is_empty() || (tasks.len() < batch_size && !self.workflow_rx.is_empty()) {
109
let limit = batch_size - tasks.len();
110
match self.workflow_rx.recv_many(&mut tasks, limit).await {
111
// 0 tasks returned means that the channel is closed
0 commit comments