Skip to content

Commit 2c13ea0

Browse files
committed
Queue algo lvl up !
1 parent 84328cc commit 2c13ea0

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

src/tasks/queue_task.rs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ use tokio::sync::Mutex;
55
use crate::epsilon::api::epsilon_api::EpsilonApi;
66
use crate::epsilon::api::epsilon_events::EpsilonEvent::SendToServer;
77
use crate::epsilon::queue::queue_provider::QueueProvider;
8+
use crate::epsilon::server::instance::VectorOfInstance;
89
use crate::epsilon::server::instance_type::InstanceType;
910
use crate::epsilon::server::state::EpsilonState;
1011
use crate::{EResult, InstanceProvider, Task};
@@ -50,7 +51,10 @@ impl Task for QueueTask {
5051
)
5152
.await?;
5253

53-
if instances_starting.is_empty() && instances_ready.is_empty() {
54+
if instances_starting.is_empty()
55+
&& (instances_ready.is_empty()
56+
|| instances_ready.get_available_slots().await? < 3)
57+
{
5458
self.instance_provider.start_instance(template_name).await?;
5559
}
5660

0 commit comments

Comments
 (0)