obelisk 0.41.3

Deterministic workflow engine
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

[[activity_exec]]
ffqn = "testing:integration/exec-stream.stream-test"
content = '''#!/usr/bin/env bash
set -exuo pipefail

echo "line1" >&2
sleep 0.1
echo "line2" >&2
'''
env_vars = ["PATH"] # for sleep

[[activity_exec]]
ffqn = "testing:integration/exec-greet.greet-include"
location = "crates/testing/test-programs/exec/greet.sh"
params = [
  { name = "name", type = "string" },
]
return_type = "result<string, string>"
env_vars = ["PATH"] # for jq

[[activity_exec]]
ffqn = "testing:integration/exec-greet.greet-inline"
content = '''
#!/usr/bin/env bash
set -exuo pipefail
raw=$(echo $1 | jq -r .)
echo "\"Hello, $raw!\""
'''
params = [
  { name = "name", type = "string" },
]
return_type = "result<string, string>"
env_vars = ["PATH"] # for jq


# Fan-out workflow to reproduce https://github.com/obeli-sk/obelisk/issues/821:
# submitting many inline exec activities at once makes their spawns race.
[[workflow_js]]
ffqn = "testing:integration/workflow-exec-fanout.exec-fanout"
content = '''
export default function exec_fanout(count) {
    const js = obelisk.createJoinSet();
    for (let i = 0; i < count; i++) {
        js.submit('testing:integration/exec-greet.greet-inline', [`name-${i}`]);
    }
    const results = [];
    for (let i = 0; i < count; i++) {
        results.push(js.joinNext());
    }
    return JSON.stringify(results);
}
'''
params = [
  { name = "count", type = "u32" },
]
return_type = "result<string, string>"

[[activity_exec]]
ffqn = "testing:integration/exec-busy.busy"
content = '''
#!/usr/bin/env bash
i=0
while true; do
    if (( i % 1000000 == 0 )); then
        echo "$i"
    fi
    ((i++))
done
'''
exec.lock_expiry.seconds = 10