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,594 Commits 242 Branches 926 Tags
feat/durable-complex-tests
Commit Graph

2594 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Gabe Ruttner
6c3a954553 Merge branch 'feat-durable-execution' into feat/durable-complex-tests 2026-03-13 11:20:29 -07:00
Gabe Ruttner
1244039e64 Fix--durable-feedback (#3240) 
* feat: duration takes ms

* fix: nondeterminism err clarity

* fix: cleanup

* chore: lint

* chore: feedback

* fix: typescript

* fix: python
 2026-03-13 10:04:03 -07:00
Gabe Ruttner
583bb6f4ba Feat--unify-running-and-evicted (#3248) 
* feat: unify running and evicted counts with filter

* chore: gen

* chore: gen lint

* fix: opsies...

* chore: gen

* chore: feedback
 2026-03-13 05:57:07 -07:00
matt
1986435d6e Feat: Simple TTL Cache (#3220) 
* feat: basic ttl cache

* feat: use ttl cache for buffered completions

* fix: don't inherit from dict

* feat: ts

* fix: stop eviction job on shutdown

* fix: add cache size
 2026-03-12 17:08:40 -04:00
matt
6fb50ce004 Feat: Wait wrapper signature improvements (#3241) 
* fix: make memo private for now

* feat: first pass at returning structured data back

* fix: json marshalling, types

* feat: wiring

* fix: sleep for return type

* chore: add comments

* fix: tests for `expr_to_timedelta`

* fix: change examples

* feat: improve asserts

* fix: pass payloads through

* fix: add hacky fallbacks to avoid breaking changes

* feat: add memo now

* feat: add test for memo now

* fix: hack for old engine test

* fix: rm restore button

* fix: one more test

* fix: ts impls

* revert: unwind engine changes (woohoo!)

* fix: payload validation

* fix: ts

* chore: gen

* feat: sleep until

* fix: return wait result on replay

* fix: data get, pydantic warning

* fix: test assert

* fix: ts memo key, make memo private

* chore: rm comment, gen again

* chore: merge and gen
 2026-03-12 12:53:03 -04:00
mrkaye97
c0204fbd8b Merge branch 'main' into feat-durable-execution 2026-03-12 12:24:32 -04:00
Mohammed Nafees
9e002a6c4c Pool gzip writers to reduce RabbitMQ message compression allocations (#3103) 
* use sync.Pool for gzip writers to avoid memory hogging

* comments

* fix deadlock failure

* copilot suggestion

* fix formatting

* use asserts

* PR comments
v0.79.35 		2026-03-12 13:09:11 +01:00
dependabot[bot]
c39743a566 chore(deps): bump github.com/posthog/posthog-go from 1.10.0 to 1.11.1 (#3246) 
Bumps [github.com/posthog/posthog-go](https://github.com/posthog/posthog-go) from 1.10.0 to 1.11.1.
- [Release notes](https://github.com/posthog/posthog-go/releases)
- [Changelog](https://github.com/PostHog/posthog-go/blob/master/CHANGELOG.md)
- [Commits](https://github.com/posthog/posthog-go/compare/v1.10.0...v1.11.1)

---
updated-dependencies:
- dependency-name: github.com/posthog/posthog-go
  dependency-version: 1.11.1
  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>
 2026-03-12 04:24:25 +00:00
dependabot[bot]
94faeb80ca chore(deps): bump ruby/setup-ruby from 1.290.0 to 1.292.0 (#3244) 
Bumps [ruby/setup-ruby](https://github.com/ruby/setup-ruby) from 1.290.0 to 1.292.0.
- [Release notes](https://github.com/ruby/setup-ruby/releases)
- [Changelog](https://github.com/ruby/setup-ruby/blob/master/release.rb)
- [Commits](6ca151fd1b...4eb9f110ba)

---
updated-dependencies:
- dependency-name: ruby/setup-ruby
  dependency-version: 1.292.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>
 2026-03-12 04:23:58 +00:00
Gabe Ruttner
7748898c59 fix: failure after cancellation (#3243) 
* fix: failure after cancellation

* chore: generate

* fix: list multiple concurrency strategies

* fix: lock concerns
v0.79.34 		2026-03-11 18:11:15 -07:00
Gabe Ruttner
3bd565c0e8 fix: durable evict at capacity (#3221) 
* fix: durable evict at capacity

* tests: capacity eviction

* chore: lint

* tests: change fixture
 2026-03-11 17:16:30 -07:00
github-actions[bot]
18f8fc45f7 chore: regenerate examples (#3242) 
Co-authored-by: GitHub Action <action@github.com>
 2026-03-11 17:34:28 -04:00
Jishnu
c77bfa9274 feat: add logs client for TS SDK (#3237) 
* feat: add logs client for typescript

* docs: add ts logs docs

* fix: lint

* bump: version, changelog

* fix: lint
 2026-03-11 17:30:04 -04:00
Julius Park
66b0d93857 Don't panic in AuthZ, bubble up instead (#3238) 2026-03-11 13:44:18 -04:00
matt
b942092ba5 Feat: env var for stream event buffer timeout (#3223) 
* feat: env var for stream event buffer timeout

* chore: gen
 2026-03-11 11:41:18 -04:00
dependabot[bot]
f9d083600f chore(deps): bump github.com/testcontainers/testcontainers-go/modules/postgres (#3235) 
Bumps [github.com/testcontainers/testcontainers-go/modules/postgres](https://github.com/testcontainers/testcontainers-go) from 0.40.0 to 0.41.0.
- [Release notes](https://github.com/testcontainers/testcontainers-go/releases)
- [Commits](https://github.com/testcontainers/testcontainers-go/compare/v0.40.0...v0.41.0)

---
updated-dependencies:
- dependency-name: github.com/testcontainers/testcontainers-go/modules/postgres
  dependency-version: 0.41.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>
 2026-03-11 04:25:54 +00:00
dependabot[bot]
0899ec1db7 chore(deps): bump google.golang.org/api from 0.270.0 to 0.271.0 (#3236) 
Bumps [google.golang.org/api](https://github.com/googleapis/google-api-go-client) from 0.270.0 to 0.271.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.270.0...v0.271.0)

---
updated-dependencies:
- dependency-name: google.golang.org/api
  dependency-version: 0.271.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>
 2026-03-11 04:24:57 +00:00
dependabot[bot]
f4772c51d8 chore(deps): bump golang.org/x/oauth2 from 0.35.0 to 0.36.0 (#3234) 
Bumps [golang.org/x/oauth2](https://github.com/golang/oauth2) from 0.35.0 to 0.36.0.
- [Commits](https://github.com/golang/oauth2/compare/v0.35.0...v0.36.0)

---
updated-dependencies:
- dependency-name: golang.org/x/oauth2
  dependency-version: 0.36.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>
 2026-03-11 04:24:27 +00:00
dependabot[bot]
c0aaa19eb9 chore(deps): bump github.com/testcontainers/testcontainers-go/modules/rabbitmq (#3233) 
Bumps [github.com/testcontainers/testcontainers-go/modules/rabbitmq](https://github.com/testcontainers/testcontainers-go) from 0.40.0 to 0.41.0.
- [Release notes](https://github.com/testcontainers/testcontainers-go/releases)
- [Commits](https://github.com/testcontainers/testcontainers-go/compare/v0.40.0...v0.41.0)

---
updated-dependencies:
- dependency-name: github.com/testcontainers/testcontainers-go/modules/rabbitmq
  dependency-version: 0.41.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>
 2026-03-11 04:24:09 +00:00
dependabot[bot]
e1edee2452 chore(deps): bump go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc (#3232) 
Bumps [go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc](https://github.com/open-telemetry/opentelemetry-go-contrib) from 0.66.0 to 0.67.0.
- [Release notes](https://github.com/open-telemetry/opentelemetry-go-contrib/releases)
- [Changelog](https://github.com/open-telemetry/opentelemetry-go-contrib/blob/main/CHANGELOG.md)
- [Commits](https://github.com/open-telemetry/opentelemetry-go-contrib/compare/zpages/v0.66.0...zpages/v0.67.0)

---
updated-dependencies:
- dependency-name: go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc
  dependency-version: 0.67.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>
 2026-03-11 04:24:05 +00:00
Julius Park
1d02a2a994 Fix owner invitation bug (#3230) 
* initial commit

* update
 2026-03-10 13:35:57 -04:00
Gabe Ruttner
4f37653776 chore: lint v0.80.0-alpha.0 v0.80.0-alpha.1 2026-03-10 09:11:51 -04:00
Gabe Ruttner
6d85bff0a6 fix: add permissions 2026-03-10 09:04:34 -04:00
Gabe Ruttner
98212cb2de Merge branch 'main' into feat-durable-execution 2026-03-10 09:01:01 -04:00
Mohammed Nafees
ab6cae4420 Test PgBouncer against our code-level partitioning logic (#3178) 
* test partition drops with pgbouncer

* dedicated DDLPool to bypass pgbouncer

* fix generate

* add env var

* min env var

* update documentation

* no go mod redundancy
v0.79.33 		2026-03-10 12:24:07 +01:00
dependabot[bot]
f36cc548c7 chore(deps): bump google.golang.org/api from 0.269.0 to 0.270.0 (#3228) 
Bumps [google.golang.org/api](https://github.com/googleapis/google-api-go-client) from 0.269.0 to 0.270.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.269.0...v0.270.0)

---
updated-dependencies:
- dependency-name: google.golang.org/api
  dependency-version: 0.270.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>
 2026-03-10 04:25:22 +00:00
dependabot[bot]
00169a8036 chore(deps): bump golang.org/x/time from 0.14.0 to 0.15.0 (#3227) 
Bumps [golang.org/x/time](https://github.com/golang/time) from 0.14.0 to 0.15.0.
- [Commits](https://github.com/golang/time/compare/v0.14.0...v0.15.0)

---
updated-dependencies:
- dependency-name: golang.org/x/time
  dependency-version: 0.15.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>
 2026-03-10 04:24:13 +00:00
dependabot[bot]
421f599432 chore(deps): bump go.opentelemetry.io/proto/otlp from 1.9.0 to 1.10.0 (#3226) 
Bumps [go.opentelemetry.io/proto/otlp](https://github.com/open-telemetry/opentelemetry-proto-go) from 1.9.0 to 1.10.0.
- [Release notes](https://github.com/open-telemetry/opentelemetry-proto-go/releases)
- [Commits](https://github.com/open-telemetry/opentelemetry-proto-go/compare/v1.9.0...v1.10.0)

---
updated-dependencies:
- dependency-name: go.opentelemetry.io/proto/otlp
  dependency-version: 1.10.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>
 2026-03-10 04:24:11 +00:00
dependabot[bot]
44caa26ed8 chore(deps): bump github.com/mattn/go-runewidth from 0.0.20 to 0.0.21 (#3225) 
Bumps [github.com/mattn/go-runewidth](https://github.com/mattn/go-runewidth) from 0.0.20 to 0.0.21.
- [Commits](https://github.com/mattn/go-runewidth/compare/v0.0.20...v0.0.21)

---
updated-dependencies:
- dependency-name: github.com/mattn/go-runewidth
  dependency-version: 0.0.21
  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>
 2026-03-10 04:24:06 +00:00
dependabot[bot]
3495d69dee chore(deps): bump golang.org/x/sync from 0.19.0 to 0.20.0 (#3224) 
Bumps [golang.org/x/sync](https://github.com/golang/sync) from 0.19.0 to 0.20.0.
- [Commits](https://github.com/golang/sync/compare/v0.19.0...v0.20.0)

---
updated-dependencies:
- dependency-name: golang.org/x/sync
  dependency-version: 0.20.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>
 2026-03-10 04:23:43 +00: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
matt
918f18f127 Fix: Clean up durable exec todos (#3214) 
* fix: comments

* fix: more todo comments

* fix: otel instrumentor

* fix: rm unused attrs

* chore: remove comment

---------

Co-authored-by: Gabe Ruttner <gabriel.ruttner@gmail.com>
 2026-03-09 16:42:23 -04:00
Julius Park
6c1bd9a074 Fix broken docs links (#3217) 
* initial commit

* idk why those files got updated

* the gh action for checking links isn't viable :/

* try again

* fix child-spawning

* fix more

* fix some more

* fix lint

* remove gh workflow for now
 2026-03-09 16:25:31 -04:00
Mohammed Nafees
11dcb60d9d Fix frontend build issues with latest cloud API (#3216) 
* isIac no longer exists on ManagedWorker

* fix lint
 2026-03-09 18:17:29 +01:00
Gabe Ruttner
ab84a0b9b0 refactor: simplify abort signal handling in durable listeners (#3215) 
* refactor: simplify abort signal handling in durable listeners

* rm: hatchet cloud

* fix: cancellation reason

* fix: tests
 2026-03-09 09:35:12 -07:00
Greg Furman
a4bd80db32 chore: Change contributing guide location (#3205) v0.79.31 v0.79.32 2026-03-09 15:13:38 +02:00
Gabe Ruttner
468de0c584 feat: handle server initiated eviction on workers (#3200) 
* refactor: ts in sync with python

* fix: waits respect abort signal

* chore: gen, lint

* fix: update key extraction logic in durable workflow example

* fix: flake

* fix: racey test

* chore: gen

* feat: send eviction to engine

* feat: handle eviction on workers

* fix: tests and invocation scoped eviction

* fix: cleanup scope

* refactor: cleanup how we do action keys in ts

* chore: gen, lint

* fix: test

* chore: lint

* fix: mock

* fix: cleanup

* chore: lint

* chore: copilot feedback

* fix: reconnect durable listener

* chore: feedback

* fix: bump worker status on wait and reconnect

* refactor: rename eviction notice

* fix: return error on query failure

* chore: lint

* chore: gen

* refactor: remove early completion

* Revert "refactor: remove early completion"

This reverts commit f756ce37b0.

* chore: remove unused param
 2026-03-09 05:16:46 -07:00
github-actions[bot]
af0f04b3f1 chore: regenerate examples (#3203) 
Co-authored-by: GitHub Action <action@github.com>
 2026-03-09 13:35:49 +02:00
dependabot[bot]
8ddeaaaa80 chore(deps): bump go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc (#3210) 
Bumps [go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc](https://github.com/open-telemetry/opentelemetry-go) from 1.41.0 to 1.42.0.
- [Release notes](https://github.com/open-telemetry/opentelemetry-go/releases)
- [Changelog](https://github.com/open-telemetry/opentelemetry-go/blob/main/CHANGELOG.md)
- [Commits](https://github.com/open-telemetry/opentelemetry-go/compare/v1.41.0...v1.42.0)

---
updated-dependencies:
- dependency-name: go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc
  dependency-version: 1.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>
 2026-03-09 04:29:24 +00:00
dependabot[bot]
b0c99b2028 chore(deps): bump hatchet-sdk in /examples/python/quickstart (#3212) 
Bumps hatchet-sdk from 1.28.0 to 1.28.1.

---
updated-dependencies:
- dependency-name: hatchet-sdk
  dependency-version: 1.28.1
  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>
 2026-03-09 04:29:21 +00:00
dependabot[bot]
a3cc01c528 chore(deps): bump go.opentelemetry.io/contrib/instrumentation/github.com/labstack/echo/otelecho (#3206) 
Bumps [go.opentelemetry.io/contrib/instrumentation/github.com/labstack/echo/otelecho](https://github.com/open-telemetry/opentelemetry-go-contrib) from 0.66.0 to 0.67.0.
- [Release notes](https://github.com/open-telemetry/opentelemetry-go-contrib/releases)
- [Changelog](https://github.com/open-telemetry/opentelemetry-go-contrib/blob/main/CHANGELOG.md)
- [Commits](https://github.com/open-telemetry/opentelemetry-go-contrib/compare/zpages/v0.66.0...zpages/v0.67.0)

---
updated-dependencies:
- dependency-name: go.opentelemetry.io/contrib/instrumentation/github.com/labstack/echo/otelecho
  dependency-version: 0.67.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>
 2026-03-09 04:28:35 +00:00
dependabot[bot]
188d613b7d chore(deps): bump ruby/setup-ruby from 1.289.0 to 1.290.0 (#3208) 
Bumps [ruby/setup-ruby](https://github.com/ruby/setup-ruby) from 1.289.0 to 1.290.0.
- [Release notes](https://github.com/ruby/setup-ruby/releases)
- [Changelog](https://github.com/ruby/setup-ruby/blob/master/release.rb)
- [Commits](19a43a6a24...6ca151fd1b)

---
updated-dependencies:
- dependency-name: ruby/setup-ruby
  dependency-version: 1.290.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>
 2026-03-09 04:27:34 +00:00
dependabot[bot]
e433223223 chore(deps): bump go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc (#3207) 
Bumps [go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc](https://github.com/open-telemetry/opentelemetry-go) from 1.41.0 to 1.42.0.
- [Release notes](https://github.com/open-telemetry/opentelemetry-go/releases)
- [Changelog](https://github.com/open-telemetry/opentelemetry-go/blob/main/CHANGELOG.md)
- [Commits](https://github.com/open-telemetry/opentelemetry-go/compare/v1.41.0...v1.42.0)

---
updated-dependencies:
- dependency-name: go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc
  dependency-version: 1.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>
 2026-03-09 04:27:32 +00:00
Gabe Ruttner
f667b7a630 chore: lint 2026-03-08 17:58:53 -04:00
Gabe Ruttner
a70b0899d1 fix: type 2026-03-08 17:50:56 -04:00
Gabe Ruttner
7e01f7ba94 Merge branch 'main' into feat-durable-execution 2026-03-08 17:50:42 -04:00
Gabe Ruttner
2a98243cd4 chore: update eslint and other packages (#3202) 
* fix: eslint for local dev

* chore: eslint v8 -> 10

* fix: flyby bug

* chore: remove many anys

* chore: update dependencies

* chore: lint
v0.79.30 		2026-03-08 13:11:51 -07:00
abelanger5
46c4297b32 feat: add callback support for tenant and tenant member updates (#3201) 
* feat: add callback support for tenant and tenant member updates

* add callbacks into tenant_invite.go
v0.79.26 v0.79.27 v0.79.28 v0.79.29 		2026-03-07 17:31:44 -05:00
Gabe Ruttner
fca52697a8 refactor: ts in sync with python (#3199) 
* refactor: ts in sync with python

* fix: waits respect abort signal

* chore: gen, lint

* fix: update key extraction logic in durable workflow example

* fix: flake

* fix: racey test

* chore: gen
 2026-03-07 05:42:42 -08:00
Gabe Ruttner
1cd9660835 rip: remove unneeded durable event log update (#3186) 
* rip: update

* refactor: start cleaning up proto defs

* refactor: finish cleaning up proto definitions

* fix: rm the kind

* refactor: rewire the server to have different methods for the different paths

* refactor: more intermediate work

* fix: variables

* fix: wire the kind through

* refactor: get it to compile

* chore: start fixing python

* fix: first pass at fixing python

* chore: rm unused sql

* fix: rm invocation count, rework some logic

* fix: alias (why does sqlc not catch this)

* fix: panics

* fix: add faster timeout to durable spawn test

* fix: task id bug

* refactor: more cleanup of types

* refactor: rm stale entries logic

* fix: rework getOrCreate logic

* fix: clean up a bunch more unneeded stuff

* fix: bug

* fix: python code

* fix: dag matches bug

* fix: add parent to dag to make it more broken, add timeout

* fix: more involved tests

* fix: dag waits

* fix: tests

---------

Co-authored-by: mrkaye97 <mrkaye97@gmail.com>
 2026-03-07 04:02:48 -08:00