e4784e89da
* feat(backend): implement flow scripts
* conditionally resolve reduced flow value
* conditionally use flow scripts based on the min worker version
* grant all to `flow_{version_lite,node}`
* do not silently discard errors
* env: add flow script feature flag
* flow script on cloud automatically
---------
Co-authored-by: Ruben Fiszel <ruben@rubenfiszel.com>
30 lines
940 B
SQL
30 lines
940 B
SQL
-- Add up migration script here
|
|
ALTER TYPE JOB_KIND ADD VALUE IF NOT EXISTS 'flowscript';
|
|
|
|
-- Same as `flow_version` but with a "lite" value (e.g. `RawScript` replaced by `FlowScript`).
|
|
CREATE TABLE flow_version_lite (
|
|
id BIGSERIAL PRIMARY KEY,
|
|
value JSONB,
|
|
FOREIGN KEY (id) REFERENCES flow_version (id) ON DELETE CASCADE
|
|
);
|
|
|
|
GRANT ALL ON flow_version_lite TO windmill_user;
|
|
GRANT ALL ON flow_version_lite TO windmill_admin;
|
|
|
|
-- Either a script or a flow value.
|
|
CREATE TABLE flow_node (
|
|
id BIGSERIAL PRIMARY KEY,
|
|
workspace_id VARCHAR(50) NOT NULL REFERENCES workspace(id),
|
|
hash BIGINT NOT NULL,
|
|
path VARCHAR(255) NOT NULL, -- flow path.
|
|
lock TEXT,
|
|
code TEXT,
|
|
flow JSONB,
|
|
FOREIGN KEY (path, workspace_id) REFERENCES flow (path, workspace_id) ON DELETE CASCADE
|
|
);
|
|
|
|
GRANT ALL ON flow_node TO windmill_user;
|
|
GRANT ALL ON flow_node TO windmill_admin;
|
|
|
|
CREATE INDEX flow_node_hash ON flow_node (hash);
|