0e316239dd
* app compiles with every ee substituted
* Replace all oss files content
* Revert "Replace all oss files content"
This reverts commit ea4017d59f.
* delete all ee
* hide all _ee files under private flag
* hide every oss stuff when private flag set
* pub use *
* gitignore and substitute script
* pub mod for ee needed for ee repo
* small mistakes
* remove oidc_oss impl
* ee ref (temp)
* ee ref
* fix --all-features selecting private in OSS CI
* ee repo ref
* allow unused
46 lines
1.2 KiB
Rust
46 lines
1.2 KiB
Rust
#[cfg(feature = "private")]
|
|
#[allow(unused)]
|
|
pub use crate::job_logger_ee::*;
|
|
|
|
#[cfg(not(feature = "private"))]
|
|
use {
|
|
crate::job_logger::CompactLogs, std::io, std::sync::atomic::AtomicU32, std::sync::Arc,
|
|
uuid::Uuid, windmill_common::DB,
|
|
};
|
|
|
|
#[cfg(all(feature = "enterprise", feature = "parquet", not(feature = "private")))]
|
|
pub(crate) async fn s3_storage(
|
|
_job_id: &Uuid,
|
|
_w_id: &str,
|
|
_db: &sqlx::Pool<sqlx::Postgres>,
|
|
_logs: &str,
|
|
_total_size: Arc<AtomicU32>,
|
|
_worker_name: &str,
|
|
) {
|
|
tracing::info!("Logs length of {_job_id} has exceeded a threshold. Implementation to store excess on s3 in not OSS");
|
|
}
|
|
|
|
#[cfg(not(feature = "private"))]
|
|
#[allow(dead_code)]
|
|
pub(crate) async fn default_disk_log_storage(
|
|
job_id: &Uuid,
|
|
_w_id: &str,
|
|
_db: &DB,
|
|
_logs: &str,
|
|
_total_size: Arc<AtomicU32>,
|
|
_compact_kind: CompactLogs,
|
|
_worker_name: &str,
|
|
) {
|
|
tracing::info!("Logs length of {job_id} has exceeded a threshold. Implementation to store excess on disk in not OSS");
|
|
}
|
|
|
|
#[cfg(not(feature = "private"))]
|
|
pub(crate) fn process_streaming_log_lines(
|
|
r: Result<Option<String>, io::Error>,
|
|
_stderr: bool,
|
|
_job_id: &Uuid,
|
|
_w_id: &str,
|
|
) -> Option<Result<String, io::Error>> {
|
|
r.transpose()
|
|
}
|