assay-engine 0.5.4

Standalone workflow + auth + dashboard HTTP server on PostgreSQL 18 + SQLite. Embeddable as a library, or run as a binary.
Documentation 
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

--! Worker for the e2e test — registers `demo.greet` + the `say_hello`
--! activity and listens on the `default` queue. Spawned by run.lua as a
--! background process; killed when the runner exits.

local engine = require("assay.engine")

local e = engine.connect({
  engine_url = env.get("ASSAY_ENGINE_URL"),
  api_key = env.get("ASSAY_ADMIN_KEY"),
})

e.workflow:register_workflow("demo.greet", function(ctx, input)
  local payload = input
  if type(payload) == "string" then payload = json.parse(payload) end
  local who = (payload and payload.name) or "anonymous"
  local greeting = ctx:execute_activity("say_hello", { name = who })
  return greeting
end)

e.workflow:register_activity("say_hello", function(_ctx, input)
  return "hello, " .. tostring(input.name)
end)

print("worker started; listening on default…")
e.workflow:listen({ queue = "default", namespace = "main" })