starred/windmill
1
0
Fork 0
mirror of https://github.com/windmill-labs/windmill.git synced 2026-10-26 00:03:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'main' into feat-go-resources

Browse Source
This commit is contained in:
pyranota
2025-05-29 23:24:54 +02:00
committed by GitHub
parent ba419c41c0 ed61d97700
commit e166349da5
13 changed files with 13151 additions and 1736 deletions
Download Patch File Download Diff File Expand all files Collapse all files
.github/workflows/validate-openapi.yml
+34
View File
@@ -0,0 +1,34 @@
name: Validate OpenAPI Spec
on:
push:
paths:
- 'backend/windmill-api/openapi*'
pull_request:
paths:
- 'backend/windmill-api/openapi*'
jobs:
validate:
runs-on: ubuntu-latest
steps:
- name: Checkout code
uses: actions/checkout@v4
- name: Set up Node.js
uses: actions/setup-node@v4
with:
node-version: '20'
- name: Install openapi-generator-cli
run: npm install @openapitools/openapi-generator-cli -g
- name: Validate openapi.yaml
run: npx @openapitools/openapi-generator-cli validate -i backend/windmill-api/openapi.yaml
- name: Validate openapi-deref.json
run: npx @openapitools/openapi-generator-cli validate -i backend/windmill-api/openapi-deref.json
# Does not work well with dereferenced yaml
# - name: Validate openapi-deref.yaml
# run: npx @openapitools/openapi-generator-cli validate -i backend/windmill-api/openapi-deref.yaml
backend/windmill-api/openapi-deref.json
+6693 -362
View File
File diff suppressed because it is too large Load Diff
backend/windmill-api/openapi-deref.yaml
+6020 -1309
View File
File diff suppressed because it is too large Load Diff
backend/windmill-api/openapi.yaml
+47 -22
View File
@@ -4896,8 +4896,6 @@ paths:
description: Script version/hash
content:
application/json:
required: false
schema:
$ref: "#/components/schemas/ScriptHistory"
@@ -5459,8 +5457,6 @@ paths:
description: Flow version
content:
application/json:
required: false
schema:
$ref: "#/components/schemas/FlowVersion"
@@ -5490,8 +5486,7 @@ paths:
operationId: getFlowVersion
parameters:
- $ref: "#/components/parameters/WorkspaceId"
- type: string
name: version
- name: version
in: path
required: true
schema:
@@ -5513,8 +5508,7 @@ paths:
operationId: updateFlowHistory
parameters:
- $ref: "#/components/parameters/WorkspaceId"
- type: string
name: version
- name: version
in: path
required: true
schema:
@@ -6142,10 +6136,8 @@ paths:
description: App version
content:
application/json:
required: false
schema:
$ref: "#/components/schemas/AppHistory"
/w/{workspace}/apps/list_paths_from_workspace_runnable/{runnable_kind}/{path}:
get:
summary: list app paths from workspace runnable
@@ -6734,11 +6726,6 @@ paths:
responses:
"201":
description: stream of created job uuids separated by \n. Lines may start with 'Error:'
example: |
a1a74c0d-708e-4539-9768-e8b3d37996bd
f0949132-5b30-48fe-bac8-873f047df810
Error: Could not re-run 0b885808-ae89-4458-af95-c1ca3a13b0a5
52b9c01d-1125-4bbb-8bee-d41f26b70066
content:
text/event-stream:
schema:
@@ -7595,7 +7582,8 @@ paths:
description: job log
content:
text/plain:
type: string
schema:
type: string
/w/{workspace}/jobs_u/get_flow_debug_info/{id}:
get:
@@ -12472,7 +12460,6 @@ paths:
text/plain:
schema:
type: string
/concurrency_groups/list:
get:
summary: List all concurrency groups
@@ -13178,7 +13165,47 @@ components:
enum: [script, flow]
schemas:
$ref: "../../openflow.openapi.yaml#/components/schemas"
# NOTE: Not so many generators and validators support this format:
# $ref: "../../openflow.openapi.yaml#/components/schemas"
# This is why it is better to inline each of schemas for better compat
OpenFlow:
$ref: "../../openflow.openapi.yaml#/components/schemas/OpenFlow"
FlowValue:
$ref: "../../openflow.openapi.yaml#/components/schemas/FlowValue"
Retry:
$ref: "../../openflow.openapi.yaml#/components/schemas/Retry"
StopAfterIf:
$ref: "../../openflow.openapi.yaml#/components/schemas/StopAfterIf"
FlowModule:
$ref: "../../openflow.openapi.yaml#/components/schemas/FlowModule"
InputTransform:
$ref: "../../openflow.openapi.yaml#/components/schemas/InputTransform"
StaticTransform:
$ref: "../../openflow.openapi.yaml#/components/schemas/StaticTransform"
JavascriptTransform:
$ref: "../../openflow.openapi.yaml#/components/schemas/JavascriptTransform"
FlowModuleValue:
$ref: "../../openflow.openapi.yaml#/components/schemas/FlowModuleValue"
RawScript:
$ref: "../../openflow.openapi.yaml#/components/schemas/RawScript"
PathScript:
$ref: "../../openflow.openapi.yaml#/components/schemas/PathScript"
PathFlow:
$ref: "../../openflow.openapi.yaml#/components/schemas/PathFlow"
ForloopFlow:
$ref: "../../openflow.openapi.yaml#/components/schemas/ForloopFlow"
WhileloopFlow:
$ref: "../../openflow.openapi.yaml#/components/schemas/WhileloopFlow"
BranchOne:
$ref: "../../openflow.openapi.yaml#/components/schemas/BranchOne"
BranchAll:
$ref: "../../openflow.openapi.yaml#/components/schemas/BranchAll"
Identity:
$ref: "../../openflow.openapi.yaml#/components/schemas/Identity"
FlowStatus:
$ref: "../../openflow.openapi.yaml#/components/schemas/FlowStatus"
FlowStatusModule:
$ref: "../../openflow.openapi.yaml#/components/schemas/FlowStatusModule"
AIProvider:
type: string
@@ -16228,10 +16255,8 @@ components:
- access_token
HubScriptKind:
name: kind
schema:
type: string
enum: [script, failure, trigger, approval]
type: string
enum: [script, failure, trigger, approval]
PolarsClientKwargs:
type: object
backend/windmill-worker/nsjail/download.rust.config.proto
+117
View File
@@ -0,0 +1,117 @@
name: "rust download script"
mode: ONCE
hostname: "rust"
log_level: ERROR
disable_rl: true
cwd: "/tmp"
clone_newnet: false
keep_caps: false
keep_env: true
mount_proc: true
mount {
src: "/bin"
dst: "/bin"
is_bind: true
}
mount {
src: "/lib"
dst: "/lib"
is_bind: true
}
mount {
src: "/lib64"
dst: "/lib64"
is_bind: true
mandatory: false
}
mount {
src: "/usr"
dst: "/usr"
is_bind: true
}
mount {
src: "/dev/null"
dst: "/dev/null"
is_bind: true
rw: true
}
mount {
dst: "/tmp"
fstype: "tmpfs"
rw: true
options: "size=500000000"
}
mount {
src: "/etc"
dst: "/etc"
is_bind: true
}
mount {
src: "/dev/random"
dst: "/dev/random"
is_bind: true
}
mount {
src: "{JOB_DIR}"
dst: "/tmp"
is_bind: true
rw: true
}
mount {
src: "/dev/urandom"
dst: "/dev/urandom"
is_bind: true
}
iface_no_lo: true
mount {
src: "{BUILD}"
dst: "{BUILD}"
is_bind: true
mandatory: false
rw: true
}
mount {
src: "{CARGO_HOME}"
dst: "{CARGO_HOME}"
is_bind: true
# Readonly
rw: false
}
mount {
src: "{BUILD}/registry"
dst: "{CARGO_HOME}/registry"
is_bind: true
mandatory: true
# Read-write
rw: true
}
mount {
src: "{BUILD}/git"
dst: "{CARGO_HOME}/git"
is_bind: true
mandatory: true
# Read-write
rw: true
}
{DEV}
backend/windmill-worker/nsjail/run.rust.config.proto
+3
View File
@@ -104,3 +104,6 @@ mount {
}
{SHARED_MOUNT}
{DEV}
backend/windmill-worker/src/rust_executor.rs
+224 -40
View File
@@ -4,7 +4,11 @@ use uuid::Uuid;
use windmill_parser_rust::parse_rust_deps_into_manifest;
use itertools::Itertools;
use tokio::{fs::File, io::AsyncReadExt, process::Command};
use tokio::{
fs::{create_dir_all, File},
io::AsyncReadExt,
process::Command,
};
use windmill_common::{
error::{self, Error},
utils::calculate_hash,
@@ -19,8 +23,8 @@ use crate::{
read_result, start_child_process, OccupancyMetrics,
},
handle_child::handle_child,
DISABLE_NSJAIL, DISABLE_NUSER, HOME_ENV, NSJAIL_PATH, PATH_ENV, PROXY_ENVS,
RUST_CACHE_DIR, TZ_ENV,
DISABLE_NSJAIL, DISABLE_NUSER, HOME_ENV, NSJAIL_PATH, PATH_ENV, PROXY_ENVS, RUST_CACHE_DIR,
TZ_ENV,
};
use windmill_common::client::AuthedClient;
@@ -28,12 +32,18 @@ use windmill_common::client::AuthedClient;
use crate::SYSTEM_ROOT;
const NSJAIL_CONFIG_RUN_RUST_CONTENT: &str = include_str!("../nsjail/run.rust.config.proto");
const NSJAIL_CONFIG_COMPILE_RUST_CONTENT: &str =
include_str!("../nsjail/download.rust.config.proto");
lazy_static::lazy_static! {
static ref HOME_DIR: String = std::env::var("HOME").expect("Could not find the HOME environment variable");
static ref CARGO_HOME: String = std::env::var("CARGO_HOME").unwrap_or_else(|_| { CARGO_HOME_DEFAULT.clone() });
static ref RUSTUP_HOME: String = std::env::var("RUSTUP_HOME").unwrap_or_else(|_| { RUSTUP_HOME_DEFAULT.clone() });
static ref CARGO_PATH: String = std::env::var("CARGO_PATH").unwrap_or_else(|_| format!("{}/bin/cargo", CARGO_HOME.as_str()));
// static ref CARGO_SWEEP_PATH: String = std::env::var("CARGO_SWEEP_PATH").unwrap_or_else(|_| format!("{}/bin/cargo-sweep", CARGO_HOME.as_str()));
static ref SWEEP_MAXSIZE: String = std::env::var("CARGO_SWEEP_MAXSIZE").unwrap_or("25GB".to_owned());
static ref NO_SHARED_BUILD_DIR: bool = std::env::var("RUST_NO_SHARED_BUILD_DIR").ok().map(|flag| flag == "true").unwrap_or(false);
}
#[cfg(windows)]
@@ -42,7 +52,20 @@ lazy_static::lazy_static! {
static ref RUSTUP_HOME_DEFAULT: String = format!("{}\\.rustup", *HOME_DIR);
}
#[cfg(unix)]
#[cfg(debug_assertions)]
const DEV_CONF_NSJAIL: &'static str = r#"
# Mount nix store for nixos to work properly
mount {
src: "/nix/store"
dst: "/nix/store"
is_bind: true
mandatory: false
}
"#;
#[cfg(not(debug_assertions))]
const DEV_CONF_NSJAIL: &'static str = "";
lazy_static::lazy_static! {
static ref CARGO_HOME_DEFAULT: String = format!("{}/.cargo", *HOME_DIR);
static ref RUSTUP_HOME_DEFAULT: String = format!("{}/.rustup", *HOME_DIR);
@@ -176,54 +199,211 @@ pub async fn generate_cargo_lockfile(
Ok(req_content)
}
async fn get_build_dir(
job: &MiniPulledJob,
job_dir: &str,
conn: &Connection,
worker_name: &str,
is_preview: bool,
) -> anyhow::Result<String> {
let (bd, run_sweep) = job
.runnable_path
.as_ref()
.and_then(|p| {
if !is_preview || *NO_SHARED_BUILD_DIR {
None
} else {
if *DISABLE_NSJAIL {
// If nsjail is disabled then entire worker has shared build directory
// It drastically improves cache hit-rate.
Some((format!("{RUST_CACHE_DIR}/build/{worker_name}"), true))
} else {
// If nsjail is enabled, having global shared directory is vulnerability and target for an attack
// Instead we either:
// 1. Create different build directory for workspace script and user. Balanced caching while mainining high degree of security.
// 2. If user is not known or something else goes wrong - use random build dir. This is equivalent to no cache at all.
Some((
format!(
"{RUST_CACHE_DIR}/build/{}@{}@{}",
&job.workspace_id,
p.replace('/', "."),
&job.created_by
),
true,
))
}
}
})
.unwrap_or((format!("{RUST_CACHE_DIR}/build/{}", Uuid::new_v4()), false));
{
let (t, r, g) = (
create_dir_all(format!("{}/target", &bd)).await,
create_dir_all(format!("{}/registry", &bd)).await,
create_dir_all(format!("{}/git", &bd)).await,
);
t.and(r)
.and(g)
.map_err(|e| anyhow::anyhow!("Could not create build dir for rust.\ne: {e}"))?;
}
if run_sweep {
// Also run sweep to make sure target isn't using too much disk
let mut sweep_cmd = Command::new(CARGO_PATH.as_str());
sweep_cmd
.current_dir(job_dir)
.env_clear()
.env("PATH", PATH_ENV.as_str())
.env("CARGO_HOME", CARGO_HOME.as_str())
.env("HOME", HOME_ENV.as_str())
.env("CARGO_TARGET_DIR", &(bd.clone() + "/target"))
.env("RUSTUP_HOME", RUSTUP_HOME.as_str())
.args(["sweep", "--maxsize", SWEEP_MAXSIZE.as_str()])
.stdout(Stdio::piped())
.stderr(Stdio::piped());
#[cfg(windows)]
{
sweep_cmd.env("SystemRoot", SYSTEM_ROOT.as_str());
sweep_cmd.env(
"TMP",
std::env::var("TMP").unwrap_or_else(|_| "C:\\tmp".to_string()),
);
sweep_cmd.env("USERPROFILE", crate::USERPROFILE_ENV.as_str());
}
let (job_id, conn, w_id, wk_name) = (
job.id.clone(),
conn.clone(),
job.workspace_id.clone(),
worker_name.to_owned(),
);
tokio::spawn(async move {
if let Err(e) = match start_child_process(sweep_cmd, CARGO_PATH.as_str()).await {
Ok(sweep_process) => {
handle_child(
&job_id,
&conn,
&mut 0,
&mut None,
sweep_process,
false,
&wk_name,
&w_id,
"cargo sweep",
None,
false,
&mut None,
None,
)
.await
}
Err(e) => Err(e),
} {
tracing::warn!(
workspace_id = %w_id,
job_id = %job_id,
"Failed to run `cargo sweep`. Rust cache may grow over time, cargo sweep is meant to clean up unused cache.\ne: {e}\n"
);
}
});
}
Ok(bd)
}
pub async fn build_rust_crate(
job_id: &Uuid,
job: &MiniPulledJob,
mem_peak: &mut i32,
canceled_by: &mut Option<CanceledBy>,
job_dir: &str,
conn: &Connection,
worker_name: &str,
w_id: &str,
base_internal_url: &str,
hash: &str,
occupancy_metrics: &mut OccupancyMetrics,
is_preview: bool,
) -> error::Result<String> {
let bin_path = format!("{}/{hash}", RUST_CACHE_DIR);
let mut build_rust_cmd = Command::new(CARGO_PATH.as_str());
build_rust_cmd
.current_dir(job_dir)
.env_clear()
.envs(PROXY_ENVS.clone())
.env("PATH", PATH_ENV.as_str())
.env("BASE_INTERNAL_URL", base_internal_url)
.env("HOME", HOME_ENV.as_str())
.env("CARGO_HOME", CARGO_HOME.as_str())
.env("RUSTUP_HOME", RUSTUP_HOME.as_str())
.args(vec!["build", "--release"])
.stdout(Stdio::piped())
.stderr(Stdio::piped());
let build_dir = get_build_dir(job, job_dir, conn, worker_name, is_preview).await?;
#[cfg(windows)]
{
build_rust_cmd.env("SystemRoot", SYSTEM_ROOT.as_str());
build_rust_cmd.env(
"TMP",
std::env::var("TMP").unwrap_or_else(|_| "C:\\tmp".to_string()),
);
build_rust_cmd.env("USERPROFILE", crate::USERPROFILE_ENV.as_str());
}
let child = if !*DISABLE_NSJAIL {
let _ = write_file(
job_dir,
"download.config.proto",
&NSJAIL_CONFIG_COMPILE_RUST_CONTENT
.replace("{JOB_DIR}", job_dir)
.replace("{CACHE_DIR}", RUST_CACHE_DIR)
.replace("{CARGO_HOME}", CARGO_HOME.as_str())
.replace("{DEV}", DEV_CONF_NSJAIL)
.replace("{BUILD}", &build_dir),
)?;
let mut nsjail_cmd = Command::new(NSJAIL_PATH.as_str());
nsjail_cmd
.current_dir(job_dir)
.env_clear()
.env("PATH", PATH_ENV.as_str())
.env("TZ", TZ_ENV.as_str())
.env("BASE_INTERNAL_URL", base_internal_url)
.envs(PROXY_ENVS.clone())
.env("HOME", HOME_ENV.as_str())
.env("CARGO_HOME", CARGO_HOME.as_str())
.env("RUSTUP_HOME", RUSTUP_HOME.as_str())
.env("CARGO_TARGET_DIR", &(build_dir.clone() + "/target"))
.args(vec![
"--config",
"download.config.proto",
"--",
CARGO_PATH.as_ref(),
"build",
])
.stdout(Stdio::piped())
.stderr(Stdio::piped());
if !is_preview {
nsjail_cmd.arg("--release");
}
start_child_process(nsjail_cmd, NSJAIL_PATH.as_str()).await?
} else {
let mut build_rust_cmd = Command::new(CARGO_PATH.as_str());
build_rust_cmd
.current_dir(job_dir)
.env_clear()
.envs(PROXY_ENVS.clone())
.env("PATH", PATH_ENV.as_str())
.env("BASE_INTERNAL_URL", base_internal_url)
.env("HOME", HOME_ENV.as_str())
.env("CARGO_HOME", CARGO_HOME.as_str())
.env("RUSTUP_HOME", RUSTUP_HOME.as_str())
.env("CARGO_TARGET_DIR", &(build_dir.clone() + "/target"))
.args(vec!["build"])
.stdout(Stdio::piped())
.stderr(Stdio::piped());
let build_rust_process = start_child_process(build_rust_cmd, CARGO_PATH.as_str()).await?;
if !is_preview {
build_rust_cmd.arg("--release");
}
#[cfg(windows)]
{
build_rust_cmd.env("SystemRoot", SYSTEM_ROOT.as_str());
build_rust_cmd.env(
"TMP",
std::env::var("TMP").unwrap_or_else(|_| "C:\\tmp".to_string()),
);
build_rust_cmd.env("USERPROFILE", crate::USERPROFILE_ENV.as_str());
}
start_child_process(build_rust_cmd, CARGO_PATH.as_str()).await?
};
handle_child(
job_id,
&job.id,
conn,
mem_peak,
canceled_by,
build_rust_process,
child,
false,
worker_name,
w_id,
&job.workspace_id,
"rust build",
None,
false,
@@ -231,16 +411,19 @@ pub async fn build_rust_crate(
None,
)
.await?;
append_logs(job_id, w_id, "\n\n", conn).await;
append_logs(&job.id, &job.workspace_id, "\n\n", conn).await;
tokio::fs::copy(
&format!("{job_dir}/target/release/main"),
&format!(
"{build_dir}/target/{}/main",
if is_preview { "debug" } else { "release" },
),
format! {"{job_dir}/main"},
)
.await
.map_err(|e| {
Error::ExecutionErr(format!(
"could not copy built binary from [...]/target/release/main to {job_dir}/main: {e:?}"
"could not copy built binary from [...]/target/.../main to {job_dir}/main: {e:?}"
))
})?;
@@ -298,6 +481,9 @@ pub async fn handle_rust_job(
let bin_path = format!("{}/{hash}", RUST_CACHE_DIR);
let remote_path = format!("{RUST_OBJECT_STORE_PREFIX}{hash}");
let reserved_variables =
get_reserved_variables(job, &client.token, conn, parent_runnable_path).await?;
let (cache, cache_logs) =
windmill_common::worker::load_cache(&bin_path, &remote_path, false).await;
@@ -332,16 +518,16 @@ pub async fn handle_rust_job(
create_args_and_out_file(client, job, job_dir, conn).await?;
build_rust_crate(
&job.id,
&job,
mem_peak,
canceled_by,
job_dir,
conn,
worker_name,
&job.workspace_id,
base_internal_url,
&hash,
occupancy_metrics,
requirements_o.is_none(),
)
.await?
};
@@ -349,9 +535,6 @@ pub async fn handle_rust_job(
let logs2 = format!("{cache_logs}\n\n--- RUST CODE EXECUTION ---\n");
append_logs(&job.id, &job.workspace_id, logs2, conn).await;
let reserved_variables =
get_reserved_variables(job, &client.token, conn, parent_runnable_path).await?;
let child = if !*DISABLE_NSJAIL {
let _ = write_file(
job_dir,
@@ -361,6 +544,7 @@ pub async fn handle_rust_job(
.replace("{CACHE_DIR}", RUST_CACHE_DIR)
.replace("{CACHE_HASH}", &hash)
.replace("{CLONE_NEWUSER}", &(!*DISABLE_NUSER).to_string())
.replace("{DEV}", DEV_CONF_NSJAIL)
.replace("{SHARED_MOUNT}", shared_mount),
)?;
let mut nsjail_cmd = Command::new(NSJAIL_PATH.as_str());
docker/DockerfileFull
+1
View File
@@ -3,6 +3,7 @@ FROM ghcr.io/windmill-labs/windmill:dev
# Rust
COPY --from=rust:1.86.0 /usr/local/cargo /usr/local/cargo
COPY --from=rust:1.86.0 /usr/local/rustup /usr/local/rustup
RUN /usr/local/cargo/bin/cargo install cargo-sweep --version ^0.7
# Ansible
RUN uv tool install ansible && [ -d "$(uv tool dir)/ansible/bin/" ] && find "$(uv tool dir)/ansible/bin/" -mindepth 1 -maxdepth 1 -type f -executable -regextype posix-extended -regex '^((.+/)?)[^.]+' -print0 | xargs -0 ln -s -t "$UV_TOOL_BIN_DIR/" || true
docker/DockerfileFullEe
+1
View File
@@ -22,6 +22,7 @@ FROM ghcr.io/windmill-labs/windmill-ee:dev
# Rust
COPY --from=rust:1.86.0 /usr/local/cargo /usr/local/cargo
COPY --from=rust:1.86.0 /usr/local/rustup /usr/local/rustup
RUN /usr/local/cargo/bin/cargo install cargo-sweep --version ^0.7
# Ansible
RUN uv tool install ansible && [ -d "$(uv tool dir)/ansible/bin/" ] && find "$(uv tool dir)/ansible/bin/" -mindepth 1 -maxdepth 1 -type f -executable -regextype posix-extended -regex '^((.+/)?)[^.]+' -print0 | xargs -0 ln -s -t "$UV_TOOL_BIN_DIR/" || true
docker/DockerfileNsjail
+1
View File
@@ -45,6 +45,7 @@ RUN apt-get update && apt-get install -y libprotobuf-dev libnl-route-3-dev
# Rust
COPY --from=rust:1.80.1 /usr/local/cargo /usr/local/cargo
COPY --from=rust:1.80.1 /usr/local/rustup /usr/local/rustup
RUN /usr/local/cargo/bin/cargo install cargo-sweep --version ^0.7
# Ansible
RUN uv tool install ansible && [ -d "$(uv tool dir)/ansible/bin/" ] && find "$(uv tool dir)/ansible/bin/" -mindepth 1 -maxdepth 1 -type f -executable -regextype posix-extended -regex '^((.+/)?)[^.]+' -print0 | xargs -0 ln -s -t "$UV_TOOL_BIN_DIR/" || true
flake.nix
+3
View File
@@ -81,11 +81,13 @@
buildInputs = buildInputs ++ (with pkgs; [
# Essentials
rust
cargo-sweep
git
xcaddy
sqlx-cli
sccache
nsjail
openapi-generator-cli
# Python
flock
@@ -186,6 +188,7 @@
# for related places search: ADD_NEW_LANG
FLOCK_PATH = "${pkgs.flock}/bin/flock";
CARGO_PATH = "${rust}/bin/cargo";
CARGO_SWEEP_PATH = "${pkgs.cargo-sweep}/bin/cargo-sweep";
DOTNET_PATH = "${pkgs.dotnet-sdk_9}/bin/dotnet";
DOTNET_ROOT = "${pkgs.dotnet-sdk_9}/share/dotnet";
ORACLE_LIB_DIR = "${pkgs.oracle-instantclient.lib}/lib";
frontend/src/lib/components/FlowBuilder.svelte
+5 -2
View File
@@ -10,7 +10,10 @@
type RawScript,
type InputTransform,
type TriggersCount,
CaptureService
CaptureService,
type HubScriptKind
} from '$lib/gen'
import { initHistory, push, redo, undo } from '$lib/history'
import {
@@ -722,7 +725,7 @@
$copilotModulesStore[idx].hubCompletions = scripts as {
path: string
summary: string
kind: string
kind: HubScriptKind
app: string
ask_id: number
id: number
frontend/src/lib/components/copilot/flow.ts
+2 -1
View File
@@ -1,6 +1,7 @@
import {
ScriptService,
type FlowModule,
type HubScriptKind,
type InputTransform,
type PathScript,
type RawScript,
@@ -22,7 +23,7 @@ export type FlowCopilotModule = {
hubCompletions: {
path: string
summary: string
kind: string
kind: HubScriptKind
app: string
ask_id: number
id: number