Matt Kaye
8f098360ef
Feat: Tenant-in-path ( #1756 )
...
* feat: put tenant in path everywhere
* fix: no need for a tenant provider
* feat: rm tenant from local storage + query params
* fix: use `tenantId` everywhere we access the id
* fix: couple more
* feat: separate hook for getting just the tenant id
* fix: fix a couple routes
* chore: tons more generated stuff
* fix: login page
* fix: some paths
* fix: onboarding create tenant page
* feat: sent ui version when creating tenant
* fix: new tenant creation on signup
* fix: naming
* feat: redirect to v1 if the tenant has a v1 ui ver
* hack: redirect button if we get stuck
* fix: cruft
* fix: login
* chore: lint
* fix: redirect to signup
* fix: null pointer
* fix: redirects
* fix: redirect to the right place on login
* fix: make `/learn` tenanted
* fix: check tenant exists
* fix: broken lesson styling
* chore: lint
* Feat: Worker Detail (#1765 )
* fix: nuke breadcrumbs
* fix: rip out query param state thing for now
* fix: rm more query state
* fix: eslint warnings
* debug: infinite loop
* fix: infinite loop
* fix: worker detail
* feat: initial work on worker filter
* fix: docs
* fix: rename worker services to pools
* fix: copy
* fix: rename
* fix: bunch more renaming
* fix: tsc
* fix: one more
* fix: more "service" refs
* fix: whoooole bunch more naming
* fix: last few
* fix: id -> name
* fix: list task runs on worker
* fix: filter state updates
* feat: worker detail query
* fix: separate components for the two pages
* fix: tsc
* feat: start sending actions over the API for worker list
* feat: actions view
* fix: styling
* fix: group pools by actions
* fix: ordering
* fix: improve sorting
* fix: copilot
* fix: don't set `replace`
2025-05-23 15:29:27 -04:00
Matt Kaye
3878bc3ca3
Feat: Remove inputs and outputs from workflow run list ( #1720 )
...
* feat: add new route
* feat: thread param through for i/o
* fix: rm inputs
* fix: children
* refactor: cleanup
* fix: rebase
* fix: nil check
* fix: use query param instead
* fix: lint
* fix: lint
* fix: wire param through
* chore: gen yet again
* fix: comma
* chore: gen
2025-05-20 16:45:09 -04:00
Matt Kaye
495fb756b5
Feat: UI Upgrade Flow ( #1750 )
...
* refactor: hook
* feat: add ui version to the tenant
* feat: add ui version to the tenant
* chore: bunch of generated stuff
* feat: return ui ver from db
* revert: flags change
* feat: wire up tenant update
* fix: type
* feat: upgrade / downgrade UI
* chore: tons more generated stuff 😬
* fix: some redirect logic
* fix: copy
* fix: non-required
* chore: gen
* fix: transformers
* fix: rm from v0 tenants
* fix: redirect
2025-05-20 16:28:50 -04:00
Matt Kaye
08bd27a869
Feat: Dynamic (Event) Filters ( #1704 )
...
* feat: add events tables
* fix: tweak PK
* feat: migration
* feat: gen models
* fix: add external id col + index
* fix: uuid pk
* fix: types
* chore: gen
* feat: add index
* Feat: Write events into OLAP tables (#1634 )
* feat: query for event creation
* feat: olap impl
* feat: wire up the olap event write
* feat: goroutine?
* feat: start wiring up inserts to triggers
* fix: no `RETURNING`
* fix: hack
* fix: inner join
* feat: attempt 2
* fix: return errors
* chore: lint
* fix: diff
* feat: add new partitions
* fix: eof
* fix: write external ids into table
* chore: gen
* fix: wiring
* fix: event deduping
* fix: insert in bulk
* fix: bug
* refactor: return type of trigger
* fix: unnest ids
* fix: unnest tenant ids
* fix: run ids in bulk insert
* feat: two bulk inserts, one tx
* fix: cruft
* fix: bug
* Update pkg/repository/v1/olap.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: rework to avoid n^2 loop
* fix: transaction timeout
* fix: lint
* fix: use error
* fix: rm penultimate version
* fix: rm penultimate test part ii
* Feat: CEL-based filtering of events (#1676 )
* feat: add optional expression to workflow trigger event ref
* feat: proto field for expression
* feat: write and parse the expression
* feat: wire up through put workflow ver request
* feat: query
* fix: naming
* fix: cleanup
* fix: rebase
* Update pkg/repository/v1/trigger.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: skip workflow on cel eval failure
* fix: zero value
* fix: cel evaluator
* fix: usage
* fix: naming + type
* fix: rm event filter from v0 defn
* feat: tests + fix typing
* fix: usage
* fix: construct input
* feat: always write events
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: select existing partitions
* feat: add prio to push event request
* feat: priority from pushed events
* fix: missed a spot
* fix: write events even if they're not tied to any workflows
* fix: revert cel event filtering
* fix: couple more
* fix: simplify
* feat: filters api
* feat: table for storing filters
* feat: migration
* fix: pk ordering
* feat: wiring up initial api
* feat: impl filter list
* feat: wire up inserts of filters
* feat: add resource hint to push event
* feat: multi-select filters
* feat: wire up resource hint on event push
* feat: filtering
* fix: small bug
* fix: rm version id
* fix: query
* fix: panic
* fix: schema
* fix: naming
* fix: rm python changes
* chore: lint
* fix: uuid hint
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: use overwrite for listing filters b/c of nullable arg
* fix: naming
* feat: add events tables
* fix: tweak PK
* feat: migration
* feat: gen models
* fix: add external id col + index
* fix: uuid pk
* fix: types
* chore: gen
* feat: add index
* Feat: Write events into OLAP tables (#1634 )
* feat: query for event creation
* feat: olap impl
* feat: wire up the olap event write
* feat: goroutine?
* feat: start wiring up inserts to triggers
* fix: no `RETURNING`
* fix: hack
* fix: inner join
* feat: attempt 2
* fix: return errors
* chore: lint
* fix: diff
* feat: add new partitions
* fix: eof
* fix: write external ids into table
* chore: gen
* fix: wiring
* fix: event deduping
* fix: insert in bulk
* fix: bug
* refactor: return type of trigger
* fix: unnest ids
* fix: unnest tenant ids
* fix: run ids in bulk insert
* feat: two bulk inserts, one tx
* fix: cruft
* fix: bug
* Update pkg/repository/v1/olap.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: rework to avoid n^2 loop
* fix: transaction timeout
* fix: lint
* fix: use error
* fix: rm penultimate version
* fix: rm penultimate test part ii
* Feat: CEL-based filtering of events (#1676 )
* feat: add optional expression to workflow trigger event ref
* feat: proto field for expression
* feat: write and parse the expression
* feat: wire up through put workflow ver request
* feat: query
* fix: naming
* fix: cleanup
* fix: rebase
* Update pkg/repository/v1/trigger.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: skip workflow on cel eval failure
* fix: zero value
* fix: cel evaluator
* fix: usage
* fix: naming + type
* fix: rm event filter from v0 defn
* feat: tests + fix typing
* fix: usage
* fix: construct input
* feat: always write events
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: select existing partitions
* feat: add prio to push event request
* feat: priority from pushed events
* fix: missed a spot
* fix: write events even if they're not tied to any workflows
* fix: revert cel event filtering
* fix: couple more
* fix: simplify
* fix: gen api
* fix: merge issues
* feat: filter delete endpoint
* fix: overwrite
* fix: delete filter api wiring
* fix: migration patch
* chore: gen
* fix: merge hell
* Revert "Revert "Feat: Events in the OLAP Repo (#1633 )" (#1706 )"
This reverts commit bf29269a27#1678 )
* feat: add events tables
* fix: tweak PK
* feat: migration
* feat: gen models
* fix: add external id col + index
* fix: uuid pk
* fix: types
* chore: gen
* feat: add index
* Feat: Write events into OLAP tables (#1634 )
* feat: query for event creation
* feat: olap impl
* feat: wire up the olap event write
* feat: goroutine?
* feat: start wiring up inserts to triggers
* fix: no `RETURNING`
* fix: hack
* fix: inner join
* feat: attempt 2
* fix: return errors
* chore: lint
* fix: diff
* feat: add new partitions
* fix: eof
* fix: write external ids into table
* chore: gen
* fix: wiring
* fix: event deduping
* fix: insert in bulk
* fix: bug
* refactor: return type of trigger
* fix: unnest ids
* fix: unnest tenant ids
* fix: run ids in bulk insert
* feat: two bulk inserts, one tx
* fix: cruft
* fix: bug
* Update pkg/repository/v1/olap.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: rework to avoid n^2 loop
* fix: transaction timeout
* fix: lint
* fix: use error
* fix: rm penultimate version
* fix: rm penultimate test part ii
* Feat: CEL-based filtering of events (#1676 )
* feat: add optional expression to workflow trigger event ref
* feat: proto field for expression
* feat: write and parse the expression
* feat: wire up through put workflow ver request
* feat: query
* fix: naming
* fix: cleanup
* fix: rebase
* Update pkg/repository/v1/trigger.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: skip workflow on cel eval failure
* fix: zero value
* fix: cel evaluator
* fix: usage
* fix: naming + type
* fix: rm event filter from v0 defn
* feat: tests + fix typing
* fix: usage
* fix: construct input
* feat: always write events
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: select existing partitions
* feat: add prio to push event request
* feat: priority from pushed events
* fix: missed a spot
* fix: write events even if they're not tied to any workflows
* fix: revert cel event filtering
* fix: couple more
* fix: simplify
* feat: initial API work
* chore: gen ts
* feat: fe skeleton
* feat: wiring up skeleton data
* feat: hook
* fix: bugs
* fix: lint on gen
* fix: couple more
* feat: wire up counts
* feat: initial events cols + styling
* feat: layout
* feat: styling
* fix: cleanup
* feat: use external ids on the FE
* fix: separate openapi spec for new events route
* fix: required param
* fix: update queries and api
* feat: event detail
* fix: page
* fix: rebase
* tweak: table
* feat: add events page to sidebar
* feat: modify queries to allow fetching by triggering event
* feat: add triggering event id to api
* chore: lint
* feat: wire up events api
* fix: rm log
* fix: gen
* feat: wire up status counts
* fix: rm time series
* fix: rm state
* fix: lint
* fix: eof
* chore: lint
* feat: wire up filters
* fix: lint
* chore: api gen
* feat: add events tables
* fix: tweak PK
* feat: migration
* feat: gen models
* fix: add external id col + index
* fix: uuid pk
* fix: types
* chore: gen
* feat: add index
* Feat: Write events into OLAP tables (#1634 )
* feat: query for event creation
* feat: olap impl
* feat: wire up the olap event write
* feat: goroutine?
* feat: start wiring up inserts to triggers
* fix: no `RETURNING`
* fix: hack
* fix: inner join
* feat: attempt 2
* fix: return errors
* chore: lint
* fix: diff
* feat: add new partitions
* fix: eof
* fix: write external ids into table
* chore: gen
* fix: wiring
* fix: event deduping
* fix: insert in bulk
* fix: bug
* refactor: return type of trigger
* fix: unnest ids
* fix: unnest tenant ids
* fix: run ids in bulk insert
* feat: two bulk inserts, one tx
* fix: cruft
* fix: bug
* Update pkg/repository/v1/olap.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: rework to avoid n^2 loop
* fix: transaction timeout
* fix: lint
* fix: use error
* fix: rm penultimate version
* fix: rm penultimate test part ii
* Feat: CEL-based filtering of events (#1676 )
* feat: add optional expression to workflow trigger event ref
* feat: proto field for expression
* feat: write and parse the expression
* feat: wire up through put workflow ver request
* feat: query
* fix: naming
* fix: cleanup
* fix: rebase
* Update pkg/repository/v1/trigger.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: skip workflow on cel eval failure
* fix: zero value
* fix: cel evaluator
* fix: usage
* fix: naming + type
* fix: rm event filter from v0 defn
* feat: tests + fix typing
* fix: usage
* fix: construct input
* feat: always write events
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: select existing partitions
* feat: add prio to push event request
* feat: priority from pushed events
* fix: missed a spot
* fix: write events even if they're not tied to any workflows
* fix: revert cel event filtering
* fix: couple more
* fix: simplify
* fix: gen api
* fix: gen
* fix: more merge issues
* chore: gen
* fix: lockfile
* fix: merge issues
* chore: gen again
* fix: rm unused fields from openapi spec
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: migration ver
* fix: insert trigger, event types
* fix: bunch o refs
* fix: migration
* fix: queries
* fix: finish wiring up inserts
* fix: misc bugs
* fix: fe filtering
* chore: gen
* fix: migration ver
* chore: lint
* fix: missed a couple
* fix: whitespace
* fix: formatting, gen
* fix: uuid id for filters
* feat: rest api for filters
* fix: tag
* feat: add event id, payload, and metadata to cel env
* fix: rename resource hint to scope
* chore: gen
* fix: same conflict, different day
* feat: send filter payload with input
* fix: lint
* fix: invert filter to "positive" case
* fix: naming
* feat: send payloads back with trigger data
* fix: add case to check if no filters were found
* fix: send additional meta back on bulk push
* fix: cleanup from self review
* fix: more small cleanup
* feat: initial pr feedback
* feat: validation
* fix: populator
* Feat: SDK changes for event filtering (#1677 )
* feat: query for event creation
* feat: wire up the olap event write
* feat: goroutine?
* feat: start wiring up inserts to triggers
* fix: no `RETURNING`
* fix: hack
* fix: inner join
* feat: attempt 2
* fix: return errors
* fix: diff
* feat: add new partitions
* fix: write external ids into table
* chore: gen
* fix: wiring
* fix: event deduping
* fix: insert in bulk
* fix: unnest ids
* fix: run ids in bulk insert
* feat: two bulk inserts, one tx
* fix: rework to avoid n^2 loop
* feat: proto field for expression
* fix: rm event filter from v0 defn
* chore: gen python
* Revert "fix: select existing partitions"
This reverts commit fefbdd5122b85c5d807c3dce3aed7d974f01a7d8.
* fix: rebase hell
* feat: prio
* chore: docs
* feat: gen ts
* feat: ts wiring
* feat: go
* fix: prio test bug
* chore: gen
* fix: validation bug
* feat: extend events client
* feat: e2e test
* chore: docs
* fix: test
* fix: unwind event filter
* fix: rm should skip
* chore: gen
* chore: gen
* chore: gen
* feat: resource hints + more e2e tests
* fix: use `cached_property` for id
* fix: raises
* fix: rm print cruft
* feat: wiring + e2e test
* chore: gen
* feat: wire up python sdk
* feat: static payload in test
* fix: use test run id in payload
* fix: longer sleeps
* feat: more tests
* feat: intermediate work
* feat: add validator for filter payload
* fix: rm cruft
* fix: event example
* fix: event example
* fix: e2e tests
* fix: finish cleaning up tests
* fix: __hash__ method
* fix: copilot comments!
* fix: apply namespaces to workflow names in a couple of the feature clients
* fix: handle case where namespace is falsey
* refactor: factor out
* fix: all the other refs to namespaced things
* fix: put `apply_namespace` on the client config
* fix: namespace overrides
* fix: implicitly use function name for hatchet task
* fix: name
* fix: refs
* chore: ver
* fix: durable tests
* feat: add a changelog!
* fix: changelog format
* feat: start wiring up filters in ts
* feat: scopes on event push
* feat: wire up triggering event id filter
* feat: initial ts e2e test work
* fix: run the test
* fix: drive-by bug in AI-gen slop
* fix: test naming
* feat: more test cleanup
* fix: api
* fix: ns override
* fix: test + API
* fix: lint
* fix: cruft
* chore: gen
* fix: dont run in ci?
* fix: wire up Go SDK
* fix: compiler
* fix: examples
* fix: event snippet, I think
* chore: docs
* Revert "fix: examples"
This reverts commit cbf33d629952336abeb2175728472+Copilot@users.noreply.github.com >
2025-05-16 15:44:28 -04:00
Matt Kaye
37482a354b
Feat: Events in the OLAP Repo ( #1707 )
...
* Revert "Revert "Feat: Events in the OLAP Repo (#1633 )" (#1706 )"
This reverts commit bf29269a27#1678 )
* feat: add events tables
* fix: tweak PK
* feat: migration
* feat: gen models
* fix: add external id col + index
* fix: uuid pk
* fix: types
* chore: gen
* feat: add index
* Feat: Write events into OLAP tables (#1634 )
* feat: query for event creation
* feat: olap impl
* feat: wire up the olap event write
* feat: goroutine?
* feat: start wiring up inserts to triggers
* fix: no `RETURNING`
* fix: hack
* fix: inner join
* feat: attempt 2
* fix: return errors
* chore: lint
* fix: diff
* feat: add new partitions
* fix: eof
* fix: write external ids into table
* chore: gen
* fix: wiring
* fix: event deduping
* fix: insert in bulk
* fix: bug
* refactor: return type of trigger
* fix: unnest ids
* fix: unnest tenant ids
* fix: run ids in bulk insert
* feat: two bulk inserts, one tx
* fix: cruft
* fix: bug
* Update pkg/repository/v1/olap.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: rework to avoid n^2 loop
* fix: transaction timeout
* fix: lint
* fix: use error
* fix: rm penultimate version
* fix: rm penultimate test part ii
* Feat: CEL-based filtering of events (#1676 )
* feat: add optional expression to workflow trigger event ref
* feat: proto field for expression
* feat: write and parse the expression
* feat: wire up through put workflow ver request
* feat: query
* fix: naming
* fix: cleanup
* fix: rebase
* Update pkg/repository/v1/trigger.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: skip workflow on cel eval failure
* fix: zero value
* fix: cel evaluator
* fix: usage
* fix: naming + type
* fix: rm event filter from v0 defn
* feat: tests + fix typing
* fix: usage
* fix: construct input
* feat: always write events
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: select existing partitions
* feat: add prio to push event request
* feat: priority from pushed events
* fix: missed a spot
* fix: write events even if they're not tied to any workflows
* fix: revert cel event filtering
* fix: couple more
* fix: simplify
* feat: initial API work
* chore: gen ts
* feat: fe skeleton
* feat: wiring up skeleton data
* feat: hook
* fix: bugs
* fix: lint on gen
* fix: couple more
* feat: wire up counts
* feat: initial events cols + styling
* feat: layout
* feat: styling
* fix: cleanup
* feat: use external ids on the FE
* fix: separate openapi spec for new events route
* fix: required param
* fix: update queries and api
* feat: event detail
* fix: page
* fix: rebase
* tweak: table
* feat: add events page to sidebar
* feat: modify queries to allow fetching by triggering event
* feat: add triggering event id to api
* chore: lint
* feat: wire up events api
* fix: rm log
* fix: gen
* feat: wire up status counts
* fix: rm time series
* fix: rm state
* fix: lint
* fix: eof
* chore: lint
* feat: wire up filters
* fix: lint
* chore: api gen
* feat: add events tables
* fix: tweak PK
* feat: migration
* feat: gen models
* fix: add external id col + index
* fix: uuid pk
* fix: types
* chore: gen
* feat: add index
* Feat: Write events into OLAP tables (#1634 )
* feat: query for event creation
* feat: olap impl
* feat: wire up the olap event write
* feat: goroutine?
* feat: start wiring up inserts to triggers
* fix: no `RETURNING`
* fix: hack
* fix: inner join
* feat: attempt 2
* fix: return errors
* chore: lint
* fix: diff
* feat: add new partitions
* fix: eof
* fix: write external ids into table
* chore: gen
* fix: wiring
* fix: event deduping
* fix: insert in bulk
* fix: bug
* refactor: return type of trigger
* fix: unnest ids
* fix: unnest tenant ids
* fix: run ids in bulk insert
* feat: two bulk inserts, one tx
* fix: cruft
* fix: bug
* Update pkg/repository/v1/olap.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: rework to avoid n^2 loop
* fix: transaction timeout
* fix: lint
* fix: use error
* fix: rm penultimate version
* fix: rm penultimate test part ii
* Feat: CEL-based filtering of events (#1676 )
* feat: add optional expression to workflow trigger event ref
* feat: proto field for expression
* feat: write and parse the expression
* feat: wire up through put workflow ver request
* feat: query
* fix: naming
* fix: cleanup
* fix: rebase
* Update pkg/repository/v1/trigger.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: skip workflow on cel eval failure
* fix: zero value
* fix: cel evaluator
* fix: usage
* fix: naming + type
* fix: rm event filter from v0 defn
* feat: tests + fix typing
* fix: usage
* fix: construct input
* feat: always write events
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: select existing partitions
* feat: add prio to push event request
* feat: priority from pushed events
* fix: missed a spot
* fix: write events even if they're not tied to any workflows
* fix: revert cel event filtering
* fix: couple more
* fix: simplify
* fix: gen api
* fix: gen
* fix: more merge issues
* chore: gen
* fix: lockfile
* fix: merge issues
* chore: gen again
* fix: rm unused fields from openapi spec
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: migration ver
* fix: insert trigger, event types
* fix: bunch o refs
* fix: migration
* fix: queries
* fix: finish wiring up inserts
* fix: misc bugs
* fix: fe filtering
* chore: lint
* fix: formatting, gen
* fix: current_date
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
2025-05-13 14:11:12 -04:00
Matt Kaye
bf29269a27
Revert "Feat: Events in the OLAP Repo ( #1633 )" ( #1706 )
...
This reverts commit d6c491badf
2025-05-12 17:17:26 -04:00
Matt Kaye
d6c491badf
Feat: Events in the OLAP Repo ( #1633 )
...
* feat: add events tables
* fix: tweak PK
* feat: migration
* feat: gen models
* fix: add external id col + index
* fix: uuid pk
* fix: types
* chore: gen
* feat: add index
* Feat: Write events into OLAP tables (#1634 )
* feat: query for event creation
* feat: olap impl
* feat: wire up the olap event write
* feat: goroutine?
* feat: start wiring up inserts to triggers
* fix: no `RETURNING`
* fix: hack
* fix: inner join
* feat: attempt 2
* fix: return errors
* chore: lint
* fix: diff
* feat: add new partitions
* fix: eof
* fix: write external ids into table
* chore: gen
* fix: wiring
* fix: event deduping
* fix: insert in bulk
* fix: bug
* refactor: return type of trigger
* fix: unnest ids
* fix: unnest tenant ids
* fix: run ids in bulk insert
* feat: two bulk inserts, one tx
* fix: cruft
* fix: bug
* Update pkg/repository/v1/olap.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: rework to avoid n^2 loop
* fix: transaction timeout
* fix: lint
* fix: use error
* fix: rm penultimate version
* fix: rm penultimate test part ii
* Feat: CEL-based filtering of events (#1676 )
* feat: add optional expression to workflow trigger event ref
* feat: proto field for expression
* feat: write and parse the expression
* feat: wire up through put workflow ver request
* feat: query
* fix: naming
* fix: cleanup
* fix: rebase
* Update pkg/repository/v1/trigger.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: skip workflow on cel eval failure
* fix: zero value
* fix: cel evaluator
* fix: usage
* fix: naming + type
* fix: rm event filter from v0 defn
* feat: tests + fix typing
* fix: usage
* fix: construct input
* feat: always write events
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: select existing partitions
* feat: add prio to push event request
* feat: priority from pushed events
* fix: missed a spot
* fix: write events even if they're not tied to any workflows
* fix: revert cel event filtering
* fix: couple more
* fix: simplify
* fix: gen api
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
2025-05-12 16:17:29 -04:00
Gabe Ruttner
00510869d2
Fix: more UI bugs -- focus on run detail view ( #1703 )
...
* wip improved signatures
* gen
* api tokens page
* codeblock
* no bg on button
* alerter empty state
* layout consistency, sidebar fixes
* sidebar tool tips
* layout improvements
* spacing
* not active top level settings
* no analytics opt out oss
* layout consistency
* pagination consistency
* only show chat if enabled
* refresh list
* fundamental responsive fixes
* navbar close on interaction
* update
* lint
* fix browser navigation
* lint
* layout
* clean console
* simplified refetch
* finally bash breadcrumbs hopefully
* lint
* no sync
* build
* invalidate
* add workflow run id to task timing
* fix parent breadcrumb
* add fallback runid
* waterfall fixes
* lint
* revert
* optional workflow run id
* remove unused prop
* lint
* fix build
* fix: dont render trigger unless needed
* variable size sheet
* minor tweaks
* global sidebar
* sheet scrolling
* header consistency
* expose classname
* selection state
* revert layout
* tmp pulse indicator
* fix: minimap
* clear breadcrumbs on exit
* error data might not be json
* interactive dag
* expand row on click
* bug fixes
* add retry counts to task summary
* wip
* feat: retry count and improved logger
* task pre
* update example
* gen
* add retry count to task event
* sheet with attempt state
* wip with attempt payloads
* event log navigation
* wip dag sidebar
* rm debug lines
* fix
* fix 404
* fix: latest default
* optimizations
* fix dag nav
* layout
* lint
* fix
* address reveiw
* use shad button
* add fixme
* review
* lint
* fix panic
2025-05-12 10:49:52 -07:00
Gabe Ruttner
3831fa3ede
feat(ts): improved custom logger ( #1652 )
...
* wip improved signatures
* feat: retry count and improved logger
* task pre
* update example
2025-05-12 09:49:18 -07:00
Gabe Ruttner
d56da1aa4c
fix: UI bugs ( #1690 )
...
* gen
* api tokens page
* codeblock
* no bg on button
* alerter empty state
* layout consistency, sidebar fixes
* sidebar tool tips
* layout improvements
* spacing
* not active top level settings
* no analytics opt out oss
* layout consistency
* pagination consistency
* only show chat if enabled
* refresh list
* fundamental responsive fixes
* navbar close on interaction
* update
* lint
* fix browser navigation
* lint
* layout
* clean console
* simplified refetch
* finally bash breadcrumbs hopefully
* lint
* no sync
* build
* invalidate
* add workflow run id to task timing
* fix parent breadcrumb
* add fallback runid
* waterfall fixes
* lint
* revert
* optional workflow run id
* remove unused prop
* lint
* fix build
2025-05-07 12:53:32 -07:00
Gabe Ruttner
09f8bd6118
feat--frontend-overhaul ( #1537 )
...
* reintegration
* fix: relative routes
* dynamic routes
* up/downgrade ui
* memoize
* fix breadcrumbs
* cleanup
* titles
* title format
* additional meta
* cli upgrade
* button
* lint
* Update frontend/app/src/next/components/runs/run-id.tsx
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* build errors
* unbind on return
* lint
* Fe overhaul run form (#1547 )
* simple trigger
* populated
* feat:trigger modal
* clear
* Update frontend/app/src/next/hooks/use-runs.tsx
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* Fe overhaul details (#1552 )
* simple trigger
* populated
* feat:trigger modal
* clear
* Update frontend/app/src/next/hooks/use-runs.tsx
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* wip activity log
* merged logs
* wip
* wip
* search box
* fudge sort
* wip improved worker sheet
* wip
* chore: improve error on dispatcher (#1538 )
* fix: empty billing context (#1553 )
* fix: empty
* precommit
* hotfix: priority nil pointer (#1555 )
* hotfix: priority on schedule workflow (#1556 )
* hotfix: priority on schedule workflow
* fix: build
* build
* lint
* build
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
Co-authored-by: abelanger5 <belanger@sas.upenn.edu >
* Fe overhaul burndown 1 (#1563 )
* chore: improve error on dispatcher (#1538 )
* fix: empty billing context (#1553 )
* fix: empty
* precommit
* hotfix: priority nil pointer (#1555 )
* hotfix: priority on schedule workflow (#1556 )
* hotfix: priority on schedule workflow
* fix: build
* Hotfix: Handle EOF Properly (#1557 )
* fix: handle EOF properly
* chore: version
* fix: debug logs
* fix: rm eof type
* hotfix: priority on cron workflow for v0 (#1558 )
* fix: one more possible null deref (#1560 )
* Hatchet Python Blog Post (#1526 )
* feat: initial pass at first parts of blog post
* feat: initial mkdocs setup
* feat: first pass at embedding mkdocs
* fix: config
* debug: paths
* fix: unwind docs hack
* feat: start working on mkdocs theme
* fix: paths
* feat: wrap up post
* fix: proof
* fix: doc links
* fix: rm docs
* fix: lint
* fix: lint
* fix: typos + tweak
* fix: tweaks
* fix: typo
* fix: cleanup
* fix: go signature and docs (#1561 )
* fix: go signature and docs
* Update examples/v1/workflows/concurrency-rr.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
---------
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* feat: toggle doc sheet
* docs: concurrency cleanup (#1562 )
* feat: storage adapter
* docs--worker-config-options (#1535 )
* docs--worker-config-options
* Update frontend/docs/pages/home/workers.mdx
Co-authored-by: abelanger5 <belanger@sas.upenn.edu >
* Update worker-configuration-options.mdx
* lint
---------
Co-authored-by: abelanger5 <belanger@sas.upenn.edu >
---------
Co-authored-by: abelanger5 <belanger@sas.upenn.edu >
Co-authored-by: Matt Kaye <mrkaye97@gmail.com >
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
* fix: bit of spacing
* single generated api
* feat: initial styling pass on runs views (#1586 )
* Feat: Workflows pages (#1577 )
* feat: simple workflows list page
* feat: refactor + add route for individual workflow
* feat: start wiring up workflow detail page
---------
Co-authored-by: Gabe Ruttner <gabriel.ruttner@gmail.com >
* fix: tsc
* fix: compiler
* fe overhaul runs bash (#1599 )
* wip sidebar
* wip: navigation
* fix nits
* tweaks
* clear filter button
* filter on click
* always scroll y
* wip time filters
* state changes
* wip
* wip
* functional, no style
* fix default
* wip
* queue metrics
* multi-select
* padding
* counts
* fix always num
* actions
* fix maxheight
* wip
* spacing
* fix: tenant state
* fix: tenant
* lint
* github page
* tenant alerting
* ingestors
* fix: tenant state
* build errrors
* empty state alerter
* dropdown only on mobile
* billing and limits
* fix form
* fix form
* wip
* wip
* env vars
* wip
* what a component
* wip
* fix inf render
* cleanup
* persistent tabs
* wip
* common actions
* deploy modal
* update
* delete
* you're a wizard harry
* Feat: Subrows in Runs View (#1595 )
* fix: type
* feat: start wiring up subrows
* fix: tsc
* fix: hook order
* fix: hack for tsc
* fix: add some margin
* fix: empty state
* fix: empty state centering
* fix: task detail links
* fix: handle error, tweak child run styling
* fix: lint
* fix: edge case
* all mw config
* wip
* fix breadcrumb hook
* fixes
* upgrade surfaces
---------
Co-authored-by: Matt Kaye <mrkaye97@gmail.com >
* bring back error toast
* toast improvements
* lint
* fix: cloud only surface
* cloud surface
* fix breadcrumbs
* feat: config view on workflow run page (#1607 )
* feat: config
* fix: rm schedule timeout
* Feat: Rework runs sidebar (#1612 )
* feat: rq devtools
* fix: badge hover
* feat: improve sidebar
* refactor: hook
* fix: input undefined
* feat: waterfall diagram and cleanup runs view (#1606 )
* merge
* merge
* fix merge issue
* rm debug lines
* case on count
* fix: display names
* colors and handle on click
---------
Co-authored-by: mrkaye97 <mrkaye97@gmail.com >
* fix: remove a ton of dead code (#1618 )
* fix: remove n+1 query (#1619 )
* Fe overhaul managed compute and onboarding (#1614 )
* fix tab state on state changes
* fix collapsed children
* setup
* layout
* layout
* move feature
* wip
* chore(deps): bump k8s.io/client-go from 0.32.3 to 0.33.0 (#1608 )
Bumps [k8s.io/client-go](https://github.com/kubernetes/client-go ) from 0.32.3 to 0.33.0.
- [Changelog](https://github.com/kubernetes/client-go/blob/master/CHANGELOG.md )
- [Commits](https://github.com/kubernetes/client-go/compare/v0.32.3...v0.33.0 )
---
updated-dependencies:
- dependency-name: k8s.io/client-go
dependency-version: 0.33.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>
* wip
* universal install
* initial migration guide
* fakefake tokens
* fake secret
* fixes
* lint
* lint
* lint
* tidy
* chore: expose clean docs on top level
* drop reo
* wip
* static
* functional
* bump go 1.23 -> 1.24
* fix: whitespace lint
* bump golangci-lint version
* wip
* try to set up go before pre commit runs
* lint
* names
* lint
* fix: session store
* wip
* normalized snips
* fix links
* blog: mergent migration (#1611 )
* universal install
* initial migration guide
* fakefake tokens
* fake secret
* fixes
* lint
* lint
* lint
* tidy
* bump go 1.23 -> 1.24
* fix: whitespace lint
* bump golangci-lint version
* try to set up go before pre commit runs
* lint
* names
* lint
* fix: session store
* fix links
---------
Co-authored-by: Alexander Belanger <alexander@hatchet.run >
* reusable state
* fix: rm unimplemented pages for now (#1615 )
* feature dir
* fixes (#1616 )
* with public auth
* completed typescript flow
* go blocks
* wip
* layout
* wip
* feat: read replica support and docs (#1617 )
* feat: read replica support and docs
* fix: load logic
* wip
* wip
* remove provider
* migrate to static
* fix block
* lint
* fix: loadtest
* add task for linting
* cleanup
* fix meta sync
* clean examples with highlights
* get snips into app
* sync
* remove fake highlights
* always gen before build
* ignore generated
* ignore
* ignore generated
* cleanup
* always start the dev server
* examples dependabot
* app examples built off sdk examples
* auto sync on main changes
* sync the quickstarts with updating dependencies
* examples and quickstart dependabots
* only examples
* functional onboarding
* fix worker detail page
* fix detail page
* lint
* init
* tested structure copy
* prepend
* ❓ to >, ‼️ to !!
* normalize
* separate example source
* multi source
* with index
* wip
* clean generation
* migrated
* cleanup
* should build
* sync before build
* fix steps
* inline
* mkdirs
* revert build
* gen docs
* static
* rm
* update examples
* lint
* fix: ts
* fix remove lines on match
* fix: client
* add snips
* dont lint examples
* fix source
* dont test examples
* exclude quickstart
* lint
* dont break examples
* cleanup
* cleanup
---------
Signed-off-by: dependabot[bot] <support@github.com >
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Alexander Belanger <alexander@hatchet.run >
Co-authored-by: Matt Kaye <mrkaye97@gmail.com >
Co-authored-by: abelanger5 <belanger@sas.upenn.edu >
* Merge main
* lint
* fix
* Update api-server-setup.mdx
* cleanup
* github state
* review and build
---------
Signed-off-by: dependabot[bot] <support@github.com >
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com >
Co-authored-by: abelanger5 <belanger@sas.upenn.edu >
Co-authored-by: Matt Kaye <mrkaye97@gmail.com >
Co-authored-by: Alexander Belanger <alexander@hatchet.run >
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2025-05-05 08:17:29 -07:00
Matt Kaye
799b5d0dcf
Feat: Add cron filters to the API ( #1641 )
...
* feat: add params to api
* feat: wire up API to accept params
* fix: queries, gen python
* chore: python version
* feat: gen ts
* chore: ver
* chore: lint
* [Python]: Feat: Workflow runs API wrapper, slightly improved typing, cruft (#1636 )
* feat: add runs list wrapper around API
* chore: version
* feat: add to standalone
* chore: docs
* fix: clean up workflow registration
* fix: add additional opts to trigger opts
* fix: warning
* fix: defaults
* fix: docs
* docs: fix cron docs
* fix: gen
2025-04-30 16:41:33 -04:00
Gabe Ruttner
ccfc0c8d60
feat: fe overhaul api changes ( #1639 )
...
* api changes
* generate
* pkg
* backmerge main
* revert to main
* revert main
2025-04-30 08:09:34 -07:00
Matt Kaye
80137736af
Feat: Priority ( #1513 )
...
* feat: initial work wiring up priorities
* fix: add default to default prio in the db
* feat: wire priority through api on wf creation
* feat: extend python test
* feat: priority for scheduled workflows
* feat: wire priority through python api
* feat: more wiring priority through the api
* feat: I think it works?
* feat: e2e test for priority
* it works!
* feat: expand tests for default priorities
* feat: e2e scheduling test
* fix: skip broken test for now
* fix: lint
* feat: add priority columns to cron and schedule ref tables
* feat: update inserts to include prio
* feat: wire up more apis
* feat: more wiring
* feat: wire up more rest api fields
* chore: cruft
* fix: more wiring
* fix: lint
* chore: gen + wire up priorities
* fix: retries
* fix: try changing fixture scope
* chore: bump version again
* feat: send priority with action payload
* fix: generate script
* Feat priority ts (#1518 )
* feat: initial work wiring up priorities
* fix: add default to default prio in the db
* feat: wire priority through api on wf creation
* feat: extend python test
* feat: priority for scheduled workflows
* feat: wire priority through python api
* feat: more wiring priority through the api
* feat: I think it works?
* feat: e2e test for priority
* it works!
* feat: expand tests for default priorities
* feat: e2e scheduling test
* chore: minor version for priority
* fix: skip broken test for now
* fix: lint
* feat: add priority columns to cron and schedule ref tables
* feat: update inserts to include prio
* feat: wire up more apis
* feat: more wiring
* feat: wire up more rest api fields
* chore: cruft
* fix: more wiring
* fix: lint
* chore: gen + wire up priorities
* fix: increase timeout
* fix: retries
* fix: try changing fixture scope
* chore: generate
* fix: set schedule priority
* feat: priority
* fix: move priority to wf
* release: 1.2.0
* rm log
* fix: import
* fix: add priority to step
---------
Co-authored-by: mrkaye97 <mrkaye97@gmail.com >
* fix: add dummy runs to priority test to prevent race conditions
* fix: non-breaking field
* fix: gen
* feat: initial pass at docs
* feat: priority in go sdk
* feat: initial work on go example
* fix: doc examples
* fix: proofread
* chore: version
* feat: go sdk
* fix: lint
* fix: declarations and add back RunAsChild
* fix: child workflows
* fix: namespace
* fix: faster child workflows
* fix: sticky
* add back run as child
---------
Co-authored-by: Gabe Ruttner <gabriel.ruttner@gmail.com >
Co-authored-by: Alexander Belanger <alexander@hatchet.run >
2025-04-14 16:22:00 -04:00
Matt Kaye
7781200123
Hotfix: Pydantic validation of actionId ( #1525 )
...
* fix: pydantic validation of action
* chore: version
2025-04-10 12:25:39 -04:00
Matt Kaye
771b733e10
Feat: Add Parent Task External ID to workflow run details, Fix input type marshalling to null ( #1505 )
...
* feat: add parent task external id to api for workflow run
* feat: wire up parent ids
* feat: custom go type for non-null json
* feat: gen
* feat: send action ids back over the api
* fix: lint
2025-04-07 23:40:13 -04:00
abelanger5
b6d077f96d
feat: show concurrency queue counts in the UI ( #1495 )
...
* feat: show concurrency queue counts in the UI
* fix: parent concurrency queues
2025-04-04 12:22:14 -04:00
abelanger5
c54bf9266c
feat(v1): tenant limits ( #1388 )
...
* feat(v1): tenant limits
* fix: migration
* fix: kill metered cache
2025-03-23 19:03:55 -07:00
abelanger5
1f2096313d
feat: v1 engine ( #1318 )
2025-03-11 14:57:13 -04:00
Gabe Ruttner
0e91542d87
wip: backoff state ( #1225 )
...
* wip: backoff state
* fix: retry state and step run start condition
* fix: missing key
* fix: gen
* chore: squash migration
* chore: rm todos
* ops: upgrade proto
2025-01-28 19:16:12 +00:00
Gabe Ruttner
13024c09bd
Feat canceled state ( #1228 )
...
* feat: add cancel state to event list
* ops: db conns
* feat: add cancelled status to wfr
* feat: mark cancelled workflow runs
2025-01-28 10:31:04 -08:00
Sean Reilly
9e961ac196
Feature add version info ( #1154 )
...
* adding a /version endpoint for the engine and a /api/v1/version endpoint for the API
* make the security optional so we don't get redirected for having auth
* lint
* upgrade protoc to the latest available version on brew
* use useQuery and clean up html
2025-01-06 10:50:04 -08:00
Sean Reilly
cbc2526c0b
add a monitoring probe ( #1108 )
...
* add a monitoring probe
---------
Co-authored-by: Sean Reilly <sean@hatchet.run >
2024-12-17 15:55:50 -05:00
Sean Reilly
279f68c3a4
add pagination for workflows ( #1109 )
...
* add some more detail to the list worklflow API endpoint and add pagination and a search function to the frontend that searches the workflow names
* switch
* remove the column filter stuff
* cleanup
* lint and clean up query
* fix linter warning
---------
Co-authored-by: Sean Reilly <sean@hatchet.run >
2024-12-12 19:33:43 +00:00
abelanger5
b0c6c7cd46
feat(go-sdk): cron and schedules API, minor fixes ( #1083 )
...
* feat(go-sdk): cron and schedules API, minor fixes
* try to improve code block and docs
* revert pre-commit
* fix: generate
* fix: put overflow in right place
* remove branch specs
2024-12-04 21:18:05 +00:00
Gabe Ruttner
23201665a6
Feat: dynamic crons fixes ( #1073 )
2024-11-26 10:47:30 -05:00
Gabe Ruttner
574eb0b67e
feat: dynamic crons ( #1000 )
...
* wip: stub schedule page
* wip: stub list
* fix: 2025 bug...
* feat: wip cron list
* feat: addl meta
* feat: expose metadata column
* feat: sort and created at
* cron to recurring
* scheduled: with statuses
* fix: links
* feat: expose schedule ids
* feat: delete run
* fix: remove search
* feat: filterable scheduled
* fix: remove broken features
* chore: lint
* rm metadata for now
* chore: lint
* chore: recurring to cron job
* fix: review comments
* fix: populator
* wip cron changes
* fix: ids are helpful
* fix: populator
* wip
* wip: create crons, stub scheduled
* wip: create schedule
* wip add trigger buttons to all the pages
* wip: reusable trigger form
* fix: hash
* fixes: cron bugs
* fixes: cron sort
* fix: out of order migrations
* fix: add internalRetryCount
* feat: api things survive version transitions
* feat: table things
* feat: delete disabled for non api
* feat: prevent delete non api
* feat: filters
* require cron name for api
* default name
* fix: migrations
* frontend improvements and migrations
* fix: pagination
---------
Co-authored-by: Alexander Belanger <alexander@hatchet.run >
2024-11-21 16:18:24 -05:00
Gabe Ruttner
44addbb47e
Feat scheduled improvements ( #992 )
...
* wip: stub schedule page
* wip: stub list
* fix: 2025 bug...
* feat: wip cron list
* feat: addl meta
* feat: expose metadata column
* feat: sort and created at
* cron to recurring
* scheduled: with statuses
* fix: links
* feat: expose schedule ids
* feat: delete run
* fix: remove search
* feat: filterable scheduled
* fix: remove broken features
* chore: lint
* rm metadata for now
* chore: lint
* chore: recurring to cron job
* fix: review comments
* fix: populator
2024-11-01 07:16:20 -04:00
Gabe Ruttner
4932e7f863
Feat sdk runtime ( #942 )
...
* feat: runtime signature
* feat: add sdk runtime to worker model
* feat: post runtime
* feat: expose sdk version on worker
* feat: go inf
* chore: gen
* chore: migrations and generation
* fix: simpler runtime
* feat: hatchet sdk ver
* fix: rm debug line
2024-10-28 13:47:12 -07:00
Gabe Ruttner
7cd08077d5
feat: improved sdk ack ( #931 )
...
* feat: add step run event reasons
* feat: ack
* fix: remove rejected reason
* fix: merge
* fix: correct buffer
* fix: consistent message
* chore: rm todo
2024-10-15 15:52:42 +00:00
abelanger5
b4c861d7a1
patch: release semaphore slots before jobs controller ( #927 )
...
* fix: don't need acks on queue checks
* patch: release semaphores early
* proper list on high queue depth
* fix: don't release on started
2024-10-02 11:36:05 -04:00
Gabe Ruttner
7d7e43d4e1
feat: pauseable workflows ( #879 )
...
* feat: pause workflow state
* feat: dont run paused workflows
* feat: skipped paused
* implement unpaused behavior for workflow runs
* fix: frontend
* fix: more frontend
* fix: imports
---------
Co-authored-by: Alexander Belanger <alexander@hatchet.run >
2024-09-29 10:58:10 -04:00
abelanger5
925b2654c8
feat: workflow run metrics view ( #912 )
...
* feat: add callbacks for workflow run completed
* add tenant id to resolve row
* add finishedBefore, finishedAfter to workflow runs query
* add more callbacks
* feat: tenant ids and loggers in callback
* feat: workflow run metrics frontend
* fix: frontend build
2024-09-27 07:38:15 -04:00
abelanger5
a1a10b4073
feat: dynamic rate limits ( #904 )
...
* wip: step run expressions on rate limits
* feat: dynamic rate limits
* chore: v0.47.0
* chore: address changes from PR review
* fix: improved error handling
* address pr review
* better error messages for step run cels, remove debug logs
* fix: hash
---------
Co-authored-by: gabriel ruttner <gabriel.ruttner@gmail.com >
2024-09-26 22:00:34 +00:00
abelanger5
840e590312
fix: frontend improvements ( #905 )
...
* fix: set time range properly on reload
* fix: small button to show queue counts for now
2024-09-24 19:08:41 -04:00
Sean Reilly
5811929928
feat: bulk inserts of events ( #887 )
...
* progress commit of bulk inserts
* in_flight: Add changes to metering finish the bulk insert
* remove an attempt to overide enforce limits
* merge in PR fixes
* update docs to add in an additional section in the User guide to describe pushing single events and pushing multiple events
* run lint fix
---------
Co-authored-by: Sean Reilly <sean@hatchet.run >
2024-09-23 09:19:39 -07:00
Sean Reilly
15c50f46b5
Partial PR - need to generate SDK - Add endpoint to get the total free worker slots for a worker and the … ( #857 )
...
* Add endpoint to get the total free worker slots for a worker and the max runs
* update to use WorkerSempahoreCount instead of checking stepRunId
* modify the query for the new table and change the interface
* bump golangci-lint make changes to name of returned data
* revert the simple example
---------
Co-authored-by: Sean Reilly <sean@hatchet.run >
2024-09-19 10:11:16 -07:00
abelanger5
d23e5d9963
feat: expression-based concurrency keys ( #889 )
...
* feat: expression-based concurrency keys
* fix: build
* fix: typos
* fix: gen
* fix: migration
* fix: remove print statements
* fix: reassignment bugs, retries on closed transport, pr review
2024-09-19 10:32:22 -04:00
Gabe Ruttner
af9ed49f1e
fix: events list view ( #878 )
...
* fix: filter by event id
* fix: run count
* feat: filter by id api
* feat: filter by Event Id
* chore: default page is runs
* feat: cancel event runs
---------
Co-authored-by: Alexander Belanger <alexander@hatchet.run >
2024-09-16 16:46:31 +00:00
Gabe Ruttner
c64c62f66a
feat: improved workflow run details page ( #821 )
...
* wip: rip prisma
* wip
* wip
* fix: lint
* wip
* wip
* gen
* wip
* wip
* fix trigger
* hide overview
* revert db changes
* feat: wrap up frontend changes and perf
* chore: generate
* chore: frontend build
* fix: workflow transformer
* fix: avoid race conditions on simultaneous parent completions
* fix: 2025 started
* feat: toast for replay/cancel
* fix: toast
---------
Co-authored-by: Alexander Belanger <alexander@hatchet.run >
2024-09-16 15:39:49 +00:00
Gabe Ruttner
460438ab22
fix: tag ( #862 )
2024-09-10 09:31:39 -07:00
abelanger5
891514b461
feat: queue v4 ( #842 )
...
* wip: v4 of queue
* fix: correct query for updating counts
* tmp: save migration files
* feat: wrap up initial queue
* fix compilation
* fix: reassigns
2024-09-06 16:12:22 -04:00
Gabe Ruttner
53be615d5f
Enhancement webhook usability ( #807 )
...
* feat: secret copier
* feat: improved form
* fix: quotes
* wip: improved flow
* feat: health check logging
* fix: page design
* fix: hard delete, no upsert
* fix: reset modal state
* fix: empty text
* fix: worker state
* fix: update only token
* fix: dont delete name
* fix: logs component
* fix: sort order
* chore: build
* fix: webhook worker cleanup
* chore: squash migrations
* Update api-contracts/openapi/paths/webhook-worker/webhook-worker.yaml
Co-authored-by: abelanger5 <belanger@sas.upenn.edu >
* chore: rename
* fix: wrong query
---------
Co-authored-by: abelanger5 <belanger@sas.upenn.edu >
2024-08-23 10:09:09 -04:00
Gabe Ruttner
9bea55438a
Fix webhook healthcheck race ( #797 )
...
* fix: race
* fix: partition no rows
* chore: move to workers tab
* feat: redirect empty worker path to all
* chore: add worker type and webhook id
* fix: upsert webhook worker
* fix: update by webhookId
* fix: only stub on create
* feat: url on worker
* chore: migration version
* fix: move
* fix: upsert
* fix: upert
* chore: fix migration
* fix: migrations
* chore: generate
2024-08-21 19:23:24 +00:00
abelanger5
84f7334a06
feat: add windows for metrics and selector ( #794 )
...
* feat: add windows for metrics and selector
* better placeholder
2024-08-20 15:29:32 +00:00
abelanger5
dd50515aeb
fix: cancelling status on frontend ( #779 )
...
* fix: cancelling status on frontend
* fix: slot grid and dedupe on slots
2024-08-13 17:01:26 +00:00
Gabe Ruttner
4ea4712d4d
refactor: performance and throughput ( #756 )
...
Refactors the queueing logic to be fairly balanced between actions, with each action backed as a separate FIFO queue. Also adds support for priority queueing and custom queues, though those aren't exposed on the API layer yet. Improves throughput to be > 5000 tasks/second on a single queue.
---------
Co-authored-by: Alexander Belanger <alexander@hatchet.run >
2024-08-12 14:38:47 +00:00
abelanger5
a245151d91
feat: add workflow kind to workflow versions ( #750 )
...
* feat: support workflow kinds
* chore: generate
2024-07-29 12:07:34 -07:00
abelanger5
c0b01f1b9b
fix: workflow runs replays and show workflow run input ( #744 )
2024-07-25 17:35:10 +00:00
Gabe Ruttner
ee68786d69
feat: sticky workers ( #695 )
...
* wip
* wip: functional query
* feat: expose affinity config
* feat: add weight to proto
* feat: upsert affinity state on worker start
* fix: linting
* feat: add upsert proto
* feat: upsert handler
* feat: revise model
* fix: labels
* feat: functional desired worker
* wip: ui
* feat: add state to step run events
* fix: filter empty keys
* fix: labels as badges
* feat: empty state and descriptive text
* chore: add todo
* chore: whitespace
* chore: cleanup
* chore: cleanup
* chore: fix hash
* chore: squash migrations
* fix: fair worker assignment
* fix: remaining slots on valid desired workers
* wip: sticky
* fix: count slots
* chore: rm log line
* feat: expose sticky config
* wip: sticky dag
* feat: expose desired worker id to trigger
* feat: trigger on desired worker
* feat: typescript docs
* feat: sticky python
* feat: py sticky children
* wip: py affinity
* serverless note
* feat: complete python examples
* linting
* fix: doc link
* chore: rm debug log
* fix: simplify list labels
* fix: typo
2024-07-22 17:20:23 -04:00
