feat: track dependency map for bun + inline script of flows

This commit is contained in:
Ruben Fiszel
2024-06-08 16:43:42 +02:00
parent c9f4ae7dd8
commit c8915063c4
26 changed files with 1929 additions and 1626 deletions

View File

@@ -197,7 +197,7 @@ pub async fn pip_compile(
.stdout(Stdio::piped())
.stderr(Stdio::piped());
let child_process = start_child_process(child_cmd, "pip-compile").await?;
append_logs(job_id.clone(), w_id.to_string(), logs, db).await;
append_logs(&job_id, &w_id, logs, db).await;
handle_child(
job_id,
db,
@@ -264,8 +264,8 @@ pub async fn handle_python_job(
.await?;
append_logs(
job.id.clone(),
job.workspace_id.to_string(),
&job.id,
&job.workspace_id,
"\n\n--- PYTHON CODE EXECUTION ---\n".to_string(),
db,
)
@@ -855,8 +855,8 @@ pub async fn handle_python_reqs(
}
if pulled.len() > 0 {
append_logs(
job_id.clone(),
w_id.to_string(),
&job_id,
&w_id,
format!(
"pulled {} from distributed cache in {}ms",
pulled.join(", "),
@@ -873,7 +873,7 @@ pub async fn handle_python_reqs(
let mut logs1 = String::new();
logs1.push_str("\n\n--- PIP INSTALL ---\n");
logs1.push_str(&format!("\n{req} is being installed for the first time.\n It will be cached for all ulterior uses."));
append_logs(job_id.clone(), w_id.to_string(), logs1, db).await;
append_logs(&job_id, w_id, logs1, db).await;
tracing::info!(
workspace_id = %w_id,