diff --git a/backend/tests/worker.rs b/backend/tests/worker.rs index 85fdbdafa0..b41ca8245b 100644 --- a/backend/tests/worker.rs +++ b/backend/tests/worker.rs @@ -2,10 +2,9 @@ use std::sync::Arc; #[cfg(feature = "enterprise")] use chrono::Timelike; -#[cfg(feature = "enterprise")] use futures::StreamExt; -use futures::{stream, Stream, StreamExt}; +use futures::{stream, Stream}; use serde::Deserialize; use serde_json::json; use sqlx::{postgres::PgListener, types::Uuid, Pool, Postgres}; @@ -15,14 +14,15 @@ use tokio::sync::RwLock; use tokio::time::{timeout, Duration}; use windmill_api_client::types::{ - CreateFlowBody, RawScript, NewScript, NewScriptLanguage + CreateFlowBody, RawScript }; -#[cfg(feature = "enterprise")] use sqlx::query; #[cfg(feature = "enterprise")] -use windmill_api_client::types::{EditSchedule, NewSchedule, ScriptArgs, NewScript, NewScriptLanguage}; +use windmill_api_client::types::{EditSchedule, NewSchedule, ScriptArgs}; + +use windmill_api_client::types::{NewScript, NewScriptLanguage}; use windmill_common::worker::WORKER_CONFIG; use windmill_common::{ @@ -2925,7 +2925,7 @@ async fn run_deployed_relative_imports(db: &Pool, script_content: Stri completed.next().await; // deployed script let script = - sqlx::query!("SELECT hash FROM script WHERE path = $1", "f/system/test_import".to_string()) + query!("SELECT hash FROM script WHERE path = $1", "f/system/test_import".to_string()) .fetch_one(&db2) .await .unwrap();