starred/windmill
1
0
Fork 0
mirror of https://github.com/windmill-labs/windmill.git synced 2026-09-07 08:02:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix tests

Browse Source
This commit is contained in:
Ruben Fiszel
2023-09-22 18:24:00 +02:00
parent ea364ad960
commit 8da819edbf
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/tests/worker.rs
+6 -6
View File
@@ -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<Postgres>, 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();