mirror/hatchet
1
0
Fork 0
mirror of https://github.com/hatchet-dev/hatchet.git synced 2026-03-17 10:15:49 -05:00
Code Issues Packages Projects Releases Wiki Activity
2,558 Commits 242 Branches 926 Tags
better_dispatch_backlog
Commit Graph

311 Commits

Author SHA1 Message Date
matt
43e7466d0f Feat: Durable Execution Revamp (#2954) 
* Feat: Durable Execution Revamp

---------

Co-authored-by: Gabe Ruttner <gabriel.ruttner@gmail.com>
 2026-03-16 11:24:29 -04:00
Gabe Ruttner
a9b5c634b3 feat(authz): Add support for additional RBAC configruation via YAML configuration (#3285) 
* feat(authz): Add support for additional RBAC permissions via YAML configuration

* feat: allowed operations
 2026-03-15 12:04:30 -07:00
Aviraj Khare
69ef87ac45 Gracefully handle empty bulk scheduled deletes (#3279) 
* fix: gracefully handle empty bulk scheduled deletes

* refactor: keep workflow schedule access consistent

* chore: drop bulk delete handler tests
 2026-03-14 20:00:43 -04:00
matt
b5351a921d Janky Fix: Extract input payloads for standalone tasks for dashboard (#3128) 
* fix: extract input payload correctly

* chore: todo -> fixme

* fix: naming + handle panic
 2026-03-13 11:03:59 -04:00
Gabe Ruttner
69951ac811 fix: add user id to context on login (#3256) 
* fix: add user id to context on login

* feat: expose extra group

* fix: add source ui to context
 2026-03-12 14:01:42 -07:00
Gabe Ruttner
6419ad33dc Feat--consistent-analytics-events (#3239) 
* chore: log when enqueue errors

* feat: standardize and improve actor model

* feat: track entire surface

* chore: remove heartbeats

* cleanup

* fix: merge

* chore: cleanup and AI

* fix: getter

* chore: feedback

* flush mu

* feat: source attribute

* feat: cli source

* fix: webhook

* feat: add server url
 2026-03-12 12:02:36 -07:00
Gabe Ruttner
7748898c59 fix: failure after cancellation (#3243) 
* fix: failure after cancellation

* chore: generate

* fix: list multiple concurrency strategies

* fix: lock concerns
 2026-03-11 18:11:15 -07:00
Julius Park
66b0d93857 Don't panic in AuthZ, bubble up instead (#3238) 2026-03-11 13:44:18 -04:00
Julius Park
ee054d39a1 RBAC v0 (#3185) 
* initial commit

* tidy up go.mod, fix errant lines

* don't do bearer token and unverified email stuff yet

* get yaml file relative to current file so it works when running from all directories

* make some style changes

* refactor authorizer to not duplicate the strings for the permissions

* refactor to another directory

* add spec validation check

* update dockerfile

* don't use dockerfiles, just use embed

* use yaml/v3
 2026-03-09 18:04:14 -04:00
Julius Park
d94a3b4718 Add queue to update scheduled cron triggers on-demand (#3149) 
Adds a queue that gets triggered whenever a cron is created, updated, or deleted that will automatically update the list of crons running in the ticker.
 2026-03-04 11:34:43 -05:00
matt
6c29e48204 Feat: Dynamic worker label assign (#3137) 
* feat: initial wiring work on desired labels

* feat: initial wiring

* chore: gen python

* fix: use the whole desired label thing instead

* fix: more wiring, improve types

* fix: sql type

* fix: len check

* chore: gen python

* fix: initial plural label work

* fix: store the labels properly on the task

* fix: skip cache on override

* fix: bug

* fix: scoping bug whoops

* chore: lint

* fix: send labels back over the api correctly

* feat: python test

* fix: lint

* fix: comment

* fix: override

* fix: namespaces, ugh

* fix: no need for error here

* chore: version

* feat: ruby, go, ts

* feat: versions

* fix: appease the rubocop

* chore: lint

* chore: bundle install

* fix: tests

* chore: lint

* chore: lint more

* fix: ts test

* fix: rb

* chore: gen

* chore: reset gemfile

* chore: reset changelog

* fix: pgroup

* fix: tests, part i

* Revert "chore: reset changelog"

This reverts commit b63bf7d3e5.

* Revert "chore: reset gemfile"

This reverts commit bb848bb6f0.

* fix: go -> golang mapping hack

* fix: go enums

* fix: appease the cop

* fix: namespace

* chore: gen
 2026-03-04 11:03:58 -05:00
abelanger5
e9eb65d9a8 feat: user callback additional methods (#3057) 
* add more opts to create user callback

* add session callbacks

* add more options to authenticate

* add full route info to routes map

* small refactor to reduce deps on session helpers
 2026-03-02 16:25:41 -05:00
Gabe Ruttner
dd48ee136a feat(agents): add new agent instruction tools (#3059) 2026-02-21 08:49:28 -08:00
matt
12c5f4cef9 fix: input in transformer (#3070) 2026-02-20 23:07:43 -05:00
Gabe Ruttner
2fdc47a6af feat: multiple slot types (#2927) 
* feat: adds support for multiple slot types, primarily motivated by durable slots

---------

Co-authored-by: mrkaye97 <mrkaye97@gmail.com>
 2026-02-17 05:43:47 -08:00
Mohammed Nafees
eefbcdc532 Return event ID after successful webhook trigger (#3039) 
* return webhook event ID on successful receive

* fix pytest

* err handling for json unmarshal

* if clause
 2026-02-16 18:36:51 +01:00
Gabe Ruttner
7875d78057 Feat: Official Ruby SDK (#3004) 
* feat: initial ruby sdk

* fix: run listener

* fix: scope

* feat: rest feature clients

* fix: bugs

* fix: concurrent register

* fix: tests and ergonomics

* docs: all of them

* chore: lint

* feat: add RBS

* feat: add GitHub Actions workflow for Ruby SDK with linting, testing, and publishing steps

* chore: lint

* refactor: simplify load path setup for Hatchet REST client and remove symlink creation

* fix: cert path

* fix: test

* fix: blocking

* fix: ensure Hatchet client is only initialized once across examples

* fix: tests

* remove: unused example

* fix: bubble up errors

* test: skip flaky for now

* remove: lifespans

* fix: durable context bugs

* fix: bulk replay

* fix: tests

* cleanup: generate tooling

* fix: integration test

* chore: lint

* release: 0.1.0

* chore: remove python comments

* refactor: remove OpenTelemetry configuration and related unused options

* fix: default no healthcheck

* chore: lockfile

* feat: register as ruby

* chore: lint

* chore: update py/ts apis to include ruby

* chore: docs pass

* chore: lint

* chore: generate

* chore: cleanup

* chore: generate examples

* tests: add e2e tests

* tests: cache examples dependencies

* fix: namespace

* fix: namespace

* fix: namespaces

* chore:lint

* fix: improve cancellation workflow polling logic and add error handling

* revert: py/ts versions
 2026-02-15 14:32:15 -08:00
Jishnu
9e0182ec77 feat: add python and typescript webhook client (#2959) 
* feat: add python webhook client

* refactor: python webhook client, webhook tests

* add: ts webhook client, example

* remove unwanted assert

* refactor: webhook update eventkey optional

* fix lint

* bump version

* fix: webhooks.create args, webhook example

* fix: infer auth_type from auth payload python

* fix: infer auth type from payload ts

* remove auth type magic strings
 2026-02-13 14:04:08 -05:00
Mohammed Nafees
40a1044b44 New UpdateLimits method for TenantResourceLimit table (#2895) 
* new UpdateLimits method to tenant limits

* WIP: clean resource limits repo

* fmt changes and cvm needs to remain

* remove unnecessary metering logic

* updated openapi

* last fixes

* PR comments

* fixes

* default limits

* fix generate test

* fix lint
 2026-02-13 18:01:46 +01:00
Mohammed Nafees
4fd7b94751 Add support for Svix webhooks (#2996) 
* support Svix webhooks

* add migration

* use http status codes

* comment fix

* custom svix verification logic

* copilot comments

* copilot comments
 2026-02-11 16:41:36 +01:00
matt
a782d9fd01 Hotfix: UUID Panics (#2944) 
* fix: panic

* fix: more panic risks

* fix: two more possible panics
 2026-02-04 15:11:08 -05:00
Jishnu
ed43cae0a2 feat: Extend webhook support for scope_expression and payload (#2874) 
* add: scope_expression and payload columns for v1_webhook

* refactor: insert or update sql cmds for v1_webhook

* feat: update api clients, openapi schema for new webhook body

* refactor: receiver and transformer for v1 webhook

* add: python sdk changes

* feat: ts sdk changes

* feat: add FE for webhook new params

* fix: scope expression empty payload

* add: support for scope and payload for go client

* fix: lint

* fix: error message UI on webhook

* fix: lint

* fix: migraiton conflict, build failure

* fix: error handling

* update docs, add tests

* fix: lint, test file name
 2026-02-04 12:44:52 -05:00
matt
b3ee6f08fc fix: don't cast user id in session.Values (#2937) 2026-02-04 11:06:12 -05:00
matt
a52a2b4b90 Fix: Resource ID type (#2929) 
* fix: resource id

* fix: userId

* fix: make resourceId string

* chore: minor cleanup

* chore: naming

* fix: user id type casts

* fix: debug message

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
 2026-02-04 10:09:33 -05:00
matt
058968c06b Refactor: Attempt II at removing pgtype.UUID everywhere + convert string UUIDs into uuid.UUID (#2894) 
* fix: add type override in sqlc.yaml

* chore: gen sqlc

* chore: big find and replace

* chore: more

* fix: clean up bunch of outdated `.Valid` refs

* refactor: remove `sqlchelpers.uuidFromStr()` in favor of `uuid.MustParse()`

* refactor: remove uuidToStr

* fix: lint

* fix: use pointers for null uuids

* chore: clean up more null pointers

* chore: clean up a bunch more

* fix: couple more

* fix: some types on the api

* fix: incorrectly non-null param

* fix: more nullable params

* fix: more refs

* refactor: start replacing tenant id strings with uuids

* refactor: more tenant id uuid casting

* refactor: fix a bunch more

* refactor: more

* refactor: more

* refactor: is that all of them?!

* fix: panic

* fix: rm scans

* fix: unwind some broken things

* chore: tests

* fix: rebase issues

* fix: more tests

* fix: nil checks

* Refactor: Make all UUIDs into `uuid.UUID` (#2897)

* refactor: remove a bunch more string uuids

* refactor: pointers and lists

* refactor: fix all the refs

* refactor: fix a few more

* fix: config loader

* fix: revert some changes

* fix: tests

* fix: test

* chore: proto

* fix: durable listener

* fix: some more string types

* fix: python health worker sleep

* fix: remove a bunch of `MustParse`s from the various gRPC servers

* fix: rm more uuid.MustParse calls

* fix: rm mustparse from api

* fix: test

* fix: merge issues

* fix: handle a bunch more uses of `MustParse` everywhere

* fix: nil id for worker label

* fix: more casting in the oss

* fix: more id parsing

* fix: stringify jwt opt

* fix: couple more bugs in untyped calls

* fix: more types

* fix: broken test

* refactor: implement `GetKeyUuid`

* chore: regen sqlc

* chore: replace pgtype.UUID again

* fix: bunch more type errors

* fix: panic
 2026-02-03 11:02:59 -05:00
abelanger5
d56dee4266 feat: durable user event log (#2861) 
* placeholder

* feat: db tables for user events (#2862)

* feat: db tables for user events

* move event payloads to payloads table, fix env var loading

* fix: address pr review comments

* missed save

* feat: optimistic scheduling (#2867)

* feat: db tables for user events

* move event payloads to payloads table, fix env var loading

* refactor: small changes to prepare optimistic txs

* feat: optimistic scheduling

* address pr review comments

* rm comments

* fix: rampup test race condition

* fix: goleak

* feat: grpc-side triggers

* fix: config and sem logic

* fix: respect optimistic scheduling env var

* add optimistic to testing matrix, remove pg-only mode

* fix cleanup of pubbuffers

* merge migrations

* last testing fixes
 2026-02-02 18:04:02 -05:00
matt
ffe9f5ce74 Log Search Frontend, Part II (#2886) 
* fix: don't toggle selection if a user is dragging

* fix: command selection state

* fix: close search bar on enter

* fix: improve search bar styling a bit, make it more consistent with designs

* chore: tsc

* Feat: Logs Frontend, Part III (#2888)

* fix: propagate retry count through properly

* feat: attempt switcher

* fix: attempt numbers

* feat: add attempt param to log query

* feat: wiring

* feat: attempt filter

* chore: changelog

* fix: use the button component

* fix: only close on enter when in FTS mode

* fix: pass retry count and log level in Go

* fix: feedback

* chore: lint

* fix: rm cruft comment
 2026-01-30 13:17:21 -05:00
matt
a3fe89ef03 Feat: Workflow input JSON schema in trigger preview (#2851) 
* feat: add input json schema to workflow version

* feat: add json schema to putworkflow proto

* feat: wire up writes of the json schema

* chore: gen python

* feat: send json schema from the python code

* feat: wiring

* feat: pass json schema into code editor

* feat: pass prop

* fix: clean up validation stuff

* feat: allow zod `input` as optional ts field

* fix: try except logic hack

* fix: rename input -> inputValidator for consistency

* chore: gen api

* fix: improve hack slightly

* chore: changelogs, versions

* feat: zod example

* chore: rework api a bit

* fix: tsc, allow schema to update

* fix: improve loading state

* fix: api cleanup, sqlc cleanup

* fix: initial mount

* chore: lint

* chore: lint

* chore: tsc

* fix: lint

* fix: unwind unneeded change

* [Python] Feat: Default additional metadata (#2876)

* Add doc about autoscaling workers (#2864)

* add doc for autoscaling workers

* oldest also in running stats

* chore(deps): bump google.golang.org/api from 0.262.0 to 0.263.0 (#2869)

Bumps [google.golang.org/api](https://github.com/googleapis/google-api-go-client) from 0.262.0 to 0.263.0.
- [Release notes](https://github.com/googleapis/google-api-go-client/releases)
- [Changelog](https://github.com/googleapis/google-api-go-client/blob/main/CHANGES.md)
- [Commits](https://github.com/googleapis/google-api-go-client/compare/v0.262.0...v0.263.0)

---
updated-dependencies:
- dependency-name: google.golang.org/api
  dependency-version: 0.263.0
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

* chore(deps): bump github.com/getsentry/sentry-go from 0.41.0 to 0.42.0 (#2870)

Bumps [github.com/getsentry/sentry-go](https://github.com/getsentry/sentry-go) from 0.41.0 to 0.42.0.
- [Release notes](https://github.com/getsentry/sentry-go/releases)
- [Changelog](https://github.com/getsentry/sentry-go/blob/master/CHANGELOG.md)
- [Commits](https://github.com/getsentry/sentry-go/compare/v0.41.0...v0.42.0)

---
updated-dependencies:
- dependency-name: github.com/getsentry/sentry-go
  dependency-version: 0.42.0
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

* chore(deps): bump hatchet-sdk in /examples/python/quickstart (#2871)

Bumps hatchet-sdk from 1.22.10 to 1.22.11.

---
updated-dependencies:
- dependency-name: hatchet-sdk
  dependency-version: 1.22.11
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

* feat: default additional meta

* feat: wiring

* chore: changelog, version

* fix: copy

* feat: add default meta to stubs

---------

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: Mohammed Nafees <hello@mnafees.me>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

* chore: migration ver

---------

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: Mohammed Nafees <hello@mnafees.me>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
 2026-01-29 11:38:25 -05:00
matt
1a5ea825bc Fix: Make metrics in graph align with badge metrics (#2858) 
* Revert "Revert "fix: make point metrics line up with badges (#2739)" (#2857)"

This reverts commit bc37fc7750.

* fix: naming
 2026-01-27 10:36:19 -05:00
matt
bc37fc7750 Revert "fix: make point metrics line up with badges (#2739)" (#2857) 
This reverts commit 26689a1b0f.
 2026-01-26 15:53:09 -05:00
matt
26689a1b0f fix: make point metrics line up with badges (#2739) 2026-01-26 14:54:20 -05:00
matt
dcf1d377ca Feat: Add order by direction param to v1LogLineList (#2849) 
* feat: add order by direction param

* fix: order ascending on existing fe

* chore: gen openapi
 2026-01-26 14:01:03 -05:00
matt
2837573b6c [Go] Feat: Webhooks feature client for the Go SDK (#2792) 
* feat: webhooks feature client

* feat: add webhook client

* feat: add v1 webhook client

* feat: example

* fix: webhook client impl

* fix: example + error handling + other client

* fix: missing webhook resources

* chore: gen
 2026-01-23 11:04:34 -05:00
matt
b093cc4878 Feat: Add search and levels to logs API (#2835) 
* feat: add log levels and search query to log query

* feat: pass levels, search through

* feat: add log level to query

* feat: wire up levels and search query
 2026-01-21 14:27:47 -05:00
abelanger5
a6e88074de refactor: have log line lookups use external id (#2822) 
* fix: modify log line query to use external id

* pass in task external id
 2026-01-20 11:17:06 -05:00
Mohammed Nafees
6eba6fa91f Billing changes (#2643) 
* make changes for billing

* progress around redesign

* meter callback

* modify limits

* upcoming subscription

* fix lint

* fix payment methods

* fix build

* PR comments

* address PR comments

* update cloud contracts

* fix migration name

* fix json serialization error

* loader and fixed for managed compute

* PR comments

* upgrade Go version

* fix migration name

* fix CI

* fix lint CI

* golangci-lint fix

* dedicated subscription
 2026-01-19 12:15:11 +01:00
Mohammed Nafees
a0233964db New onboarding flow (#2757) 
Updates the onboarding flow to make it CLI-based.
 2026-01-16 10:09:44 -05:00
matt
3981626804 Fix: Concurrency display on workflow page (#2780) 
* chore: add task concurrency

* feat: wire up new concurrency field

* feat: clean up table

* feat: some page cleanup

* chore: cleanup

* chore: revert python changes

* feat: code highlighter

* chore: lint
 2026-01-12 15:44:44 -05:00
abelanger5
32188b5a85 fix: better error on deprecated endpoints (#2763) 2026-01-08 11:32:14 -05:00
Andrei Gaspar
4dda2b2884 Send create:user Event from OAuth Flow (#2683) 
* feat: Send create:user event from OAuth flow

* feat: Implement user and tenant creation events in callbacks

* move callback into cb.Do

---------

Co-authored-by: Alexander Belanger <alexander@hatchet.run>
 2026-01-06 14:06:38 -05:00
abelanger5
9f463e92d6 refactor: move v1 packages, remove webhook worker references (#2749) 
* chore: move v1 packages, remove webhook worker references

* chore: move msgqueue

* fix: relative paths in sqlc.yaml
 2026-01-02 11:42:40 -05:00
abelanger5
f82d3bd071 refactor: consolidate repository methods (#2730) 
* refactor: remove v0 paths from codebase

* remove uiVersion references

* refactor: remove v0-exclusive database queries

* remove webhook test

* chore: move api token repository

* chore: move dispatcher repository to v1

* chore: move health repository to v1

* chore: remove event repository

* remove some unused repositories

* chore: move mq implementation to v1

* chore: consolidate rate limit implementations

* chore: move security check to v1 repository

* chore: move slack to v1 repository

* chore: move sns implementation to v1 repository

* clean up step repository

* chore: move tenant invite to v1 repository

* chore: move limits, workers, tenant alerts to v1 repository

* chore: move user, tenant, userSession to v1 repository

* chore: move ticker to v1 repository

* chore: move scheduled workflows to v1 repository

* chore: remove workflows

* fix: remove pointer for limits config file

* propagate cache value to api token

* propagate cache durations
 2025-12-31 16:35:46 -05:00
abelanger5
f57ebf7546 refactor: remove v0-exclusive database queries (#2729) 
* refactor: remove v0 paths from codebase

* remove uiVersion references

* refactor: remove v0-exclusive database queries

* remove webhook test
 2025-12-31 09:36:12 -05:00
abelanger5
dd9c36c315 refactor: remove v0 paths from codebase (#2728) 
* refactor: remove v0 paths from codebase

* remove uiVersion references
 2025-12-30 09:57:00 -05:00
matt
735742c466 Revert "Revert "chore: run list query optimizations (#2670)" (#2708)" (#2720) 
This reverts commit 2f301e55cf.
 2025-12-26 10:11:02 -07:00
Mohammed Nafees
58758d35b2 Publish COULD_NOT_SEND_TO_WORKER OLAP event due to worker backlog (#2710) 
* could not send to worker OLAP event

* fix lint and PR comments

* submodule GHA

* remove submodule

* no gitsubmodule

* fix migration

* revert sdk workflows

* revert sdk workflows

* revert sdk workflows
 2025-12-26 09:35:15 -07:00
matt
2f301e55cf Revert "chore: run list query optimizations (#2670)" (#2708) 
This reverts commit 87b57febe8.
 2025-12-23 17:10:47 -05:00
matt
b65c6de53f Feat: Hatchet Metrics Monitoring, I (#2699) 
* Revert "Revert "Feat: Hatchet Metrics Monitoring, I (#2480)" (#2698)"

This reverts commit b87150767a.

* go mod tidy

---------

Co-authored-by: Mohammed Nafees <hello@mnafees.me>
 2025-12-23 20:14:14 +01:00
Gabe Ruttner
87b57febe8 chore: run list query optimizations (#2670) 
* add missing tenant index

* fix span name

* parallelize

* instrument tenant id attribute

* feedback

* cleanup migrations

* rename migration

* correct version

* cleanup
 2025-12-23 08:59:13 -08:00
Gabe Ruttner
670e015fe4 feat: improved error boundaries (#2689) 
* improved error boundaries

* dont panic on invalid uuid..

* resources

* rm bad test

* lint

* feedback

* feedback
 2025-12-23 08:01:01 -08:00