loops: cargo fmt --all (unblock CI)
This commit is contained in:
@@ -235,11 +235,7 @@ pub struct AgentSlot {
|
|||||||
pub role_slot: Option<String>,
|
pub role_slot: Option<String>,
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn set_agents(
|
pub async fn set_agents(pool: &PgPool, loop_id: Uuid, slots: &[AgentSlot]) -> Result<(), DbError> {
|
||||||
pool: &PgPool,
|
|
||||||
loop_id: Uuid,
|
|
||||||
slots: &[AgentSlot],
|
|
||||||
) -> Result<(), DbError> {
|
|
||||||
let mut tx = pool.begin().await?;
|
let mut tx = pool.begin().await?;
|
||||||
sqlx::query!("DELETE FROM loop_agents WHERE loop_id = $1", loop_id)
|
sqlx::query!("DELETE FROM loop_agents WHERE loop_id = $1", loop_id)
|
||||||
.execute(&mut *tx)
|
.execute(&mut *tx)
|
||||||
@@ -297,10 +293,7 @@ pub async fn set_teams(pool: &PgPool, loop_id: Uuid, ids: &[Uuid]) -> Result<(),
|
|||||||
}
|
}
|
||||||
|
|
||||||
pub async fn teams(pool: &PgPool, loop_id: Uuid) -> Result<Vec<Uuid>, DbError> {
|
pub async fn teams(pool: &PgPool, loop_id: Uuid) -> Result<Vec<Uuid>, DbError> {
|
||||||
let rows = sqlx::query!(
|
let rows = sqlx::query!("SELECT team_id FROM loop_teams WHERE loop_id = $1", loop_id,)
|
||||||
"SELECT team_id FROM loop_teams WHERE loop_id = $1",
|
|
||||||
loop_id,
|
|
||||||
)
|
|
||||||
.fetch_all(pool)
|
.fetch_all(pool)
|
||||||
.await?;
|
.await?;
|
||||||
Ok(rows.into_iter().map(|r| r.team_id).collect())
|
Ok(rows.into_iter().map(|r| r.team_id).collect())
|
||||||
@@ -326,10 +319,7 @@ pub async fn set_orgs(pool: &PgPool, loop_id: Uuid, ids: &[Uuid]) -> Result<(),
|
|||||||
}
|
}
|
||||||
|
|
||||||
pub async fn orgs(pool: &PgPool, loop_id: Uuid) -> Result<Vec<Uuid>, DbError> {
|
pub async fn orgs(pool: &PgPool, loop_id: Uuid) -> Result<Vec<Uuid>, DbError> {
|
||||||
let rows = sqlx::query!(
|
let rows = sqlx::query!("SELECT org_id FROM loop_orgs WHERE loop_id = $1", loop_id,)
|
||||||
"SELECT org_id FROM loop_orgs WHERE loop_id = $1",
|
|
||||||
loop_id,
|
|
||||||
)
|
|
||||||
.fetch_all(pool)
|
.fetch_all(pool)
|
||||||
.await?;
|
.await?;
|
||||||
Ok(rows.into_iter().map(|r| r.org_id).collect())
|
Ok(rows.into_iter().map(|r| r.org_id).collect())
|
||||||
|
|||||||
Reference in New Issue
Block a user