7 Commits

Author	SHA1	Message	Date
Gabe Ruttner	c8b59d1cc1	Feat add additional meta to trigger (#458) ... * feat: add additional metadata to sdk * docs: metadata * fix: build * feat: filter gif	2024-05-08 10:07:28 -04:00
abelanger5	4ce1dd8632	feat: multi-workflow runs listener on a single endpoint ... * new api-contract for workflow run events * feat: initial implementation for new subscribe listener * fix: sync issues and send workflow runs immediately * refactor: add context to all engine db queries, fix deadlocking query * fix: use new ctx for deleting dispatcher and ticker * add cancellation reasons * fix: docs linting --------- Co-authored-by: gabriel ruttner <gabriel.ruttner@gmail.com>	2024-04-18 20:55:11 -04:00
Gabe Ruttner	d8b6843dec	feat: streaming events (#309) ... * feat: add stream event model * docs: how to work with db models * feat: put stream event * chore: rm comments * feat: add stream resource type * feat: enqueue stream event * fix: contracts * feat: protos * chore: set properties correctly for typing * fix: stream example * chore: rm old example * fix: async on * fix: bytea type * fix: worker * feat: put stream data * feat: stream type * fix: correct queue * feat: streaming payloads * fix: cleanup * fix: validation * feat: example file streaming * chore: rm unused query * fix: tenant check and read only consumer * fix: check tenant-steprun relation * Update prisma/schema.prisma Co-authored-by: abelanger5 <belanger@sas.upenn.edu> * chore: generate protos * chore: rename migration * release: 0.20.0 * feat(go-sdk): implement streaming in go --------- Co-authored-by: gabriel ruttner <gabe@hatchet.run> Co-authored-by: abelanger5 <belanger@sas.upenn.edu>	2024-04-01 15:46:21 -04:00
abelanger5	77e5d2b77c	feat(go-sdk): spawnWorkflow method and get up to speed with other sdks (#297) ... * feat(go-sdk): spawnWorkflow method and get up to speed with other sdks * fix: manual trigger example * fix: linting errors * fix: double serialization from go sdk * fix: spawn workflow logic and procedural example * test(e2e): add procedural test * fix: panic in e2e test * fix: e2e test preparation * fix: api server url in test.yml * fix: load test server url * chore: make num children configurable * address pr review	2024-03-29 14:07:39 -07:00
Luca Steeb	9b68115fb5	refactor: cleanup functions in api + worker (#192)	2024-03-02 00:37:02 +07:00
abelanger5	df3f540748	feat: add retries to the engine and SDKs (#171) ... This PR adds support for retrying failed step runs against the engine and SDKs. This was tested up to 30 retries per step run, with both failure and success at the 30th step run. Each SDK now has a `retries` configurable param for steps when declaring a workflow.	2024-02-16 13:00:22 -05:00
abelanger5	82d7995343	feat: manual triggers and give clients a hook into step run events (#141) ... * feat: pubsub for clients, more qol stuff * fix: generate sqlc files * chore: linting and comments	2024-02-02 12:52:34 -05:00