mirror of
https://github.com/windmill-labs/windmill.git
synced 2026-08-21 08:02:26 +00:00
Ruben Fiszel
76 lines
2.7 KiB
TypeScript
76 lines
2.7 KiB
TypeScript
export const PYTHON_INIT_CODE = `import os
|
|
import wmill
|
|
from datetime import datetime
|
|
|
|
"""
|
|
Use Cmd/Ctrl + S to autoformat the code.
|
|
The client is used to interact with windmill itself through its standard API.
|
|
One can explore the methods available through autocompletion of \`wmill.XXX\`.
|
|
"""
|
|
|
|
def main(name: str = "Nicolas Bourbaki",
|
|
age: int = 42,
|
|
obj: dict = {"even": "dicts"},
|
|
l: list = ["or", "lists!"],
|
|
file_: bytes = bytes(0),
|
|
dtime: datetime = datetime.now()):
|
|
"""A main function is required for the script to be able to accept arguments.
|
|
Types are recommended."""
|
|
print(f"Hello World and a warm welcome especially to {name}")
|
|
print("and its acolytes..", age, obj, l, len(file_), dtime)
|
|
# retrieve variables, including secrets by querying the windmill platform.
|
|
# secret fetching is audited by windmill.
|
|
secret = wmill.get_variable("g/all/pretty_secret")
|
|
print(f"The env variable at \`g/all/pretty_secret\`: {secret}")
|
|
# interact with the windmill platform to get the version
|
|
version = wmill.get_version()
|
|
# fetch reserved variables as environment variables
|
|
user = os.environ.get("WM_USERNAME")
|
|
# the return value is then parsed and can be retrieved by other scripts conveniently
|
|
return {"version": version, "splitted": name.split(), "user": user}
|
|
`
|
|
export const DENO_INIT_CODE = `
|
|
// to import most npm packages without deno.land, use esm:
|
|
// import { toWords } from "https://esm.sh/number-to-words"
|
|
// import * as wmill from 'https://deno.land/x/windmill@v${__pkg__.version}/mod.ts'
|
|
|
|
export async function main(
|
|
a: number,
|
|
b: "my" | "enum",
|
|
c: { nested: "object" },
|
|
d: string = "default arg",
|
|
) {
|
|
// let x = await wmill.getVariable('u/user/foo')
|
|
return { foo: a };
|
|
}
|
|
`
|
|
|
|
export const DENO_INIT_CODE_TRIGGER = `import * as wmill from 'https://deno.land/x/windmill@v${__pkg__.version}/mod.ts'
|
|
|
|
export async function main() {
|
|
|
|
// A common trigger script would follow this pattern:
|
|
// 1. Get the last saved state
|
|
// let state = wmill.getInternalState()
|
|
// 2. Get the actual state from the external service
|
|
// let newState = await (await fetch('https://hacker-news.firebaseio.com/v0/topstories.json')).json()
|
|
// 3. Compare the two states and update the internal state
|
|
// wmill.setInternalState(newState)
|
|
// 4. Return the new ros
|
|
// return range from (state to newState)
|
|
|
|
return [1,2,3]
|
|
|
|
// In subsequent scripts, you may refer to each row/value returned by the trigger script using
|
|
// 'flow_input._value'
|
|
}
|
|
`
|
|
|
|
export function initialCode(language: 'deno' | 'python3', is_trigger: boolean): string {
|
|
return language === 'deno'
|
|
? is_trigger
|
|
? DENO_INIT_CODE_TRIGGER
|
|
: DENO_INIT_CODE
|
|
: PYTHON_INIT_CODE
|
|
}
|