This repository was archived by the owner on Mar 26, 2025. It is now read-only.
![dependabot[bot]](https://avatars.githubusercontent.com/in/29110?v=4&size=40){kind=avatar}
1 file changed
+1
-1
lines changed- api-contracts/dispatcher/dispatcher.proto+1
- api-contracts/openapi/components/schemas/workflow_run.yaml+1
- api/v1/server/oas/gen/openapi.gen.go+181-180
- cmd/hatchet-engine/engine/run.go+1
- examples/assignment-affinity/run.go+1-1
- examples/loadtest/cli/cli_e2e_test.go+2-2
- examples/manual-trigger/trigger/main.go+3-3
- examples/procedural/main.go+2-2
- examples/stream-event/main.go+2-2
- frontend/app/src/lib/api/generated/data-contracts.ts+1
- frontend/app/src/pages/main/workflow-runs/$run/components/step-run-events.tsx+1
- frontend/app/src/pages/main/workflow-runs/$run/v2components/events-columns.tsx+1
- go.mod+3-2
- go.sum+5-4
- internal/queueutils/pool.go+2-2
- internal/services/controllers/jobs/controller.go+58-7
- internal/services/controllers/jobs/queue.go+80-43
- internal/services/controllers/workflows/controller.go+1-1
- internal/services/dispatcher/contracts/dispatcher.pb.go+101-96
- internal/services/dispatcher/dispatcher.go+7-12
- internal/services/dispatcher/server.go+50
- internal/services/shared/tasktypes/job.go+14-2
- pkg/client/admin.go+25-13
- pkg/client/client.go+3-2
- pkg/client/rest/gen.go+1
- pkg/client/workflow.go+23-15
- pkg/config/loader/loader.go+21-1
- pkg/config/server/server.go+3
- pkg/repository/buffer/buffered.go+11-11
- pkg/repository/buffer/buffered_test.go+11-11
- pkg/repository/buffer/bulk_events.go+206
- pkg/repository/buffer/tenant_buffer.go+7-8
- pkg/repository/buffer/tenant_buffer_test.go+7-7
- pkg/repository/prisma/db/db_gen.go+23.5k-20.3k
- pkg/repository/prisma/dbsqlc/lease.sql+48
- pkg/repository/prisma/dbsqlc/lease.sql.go+141
- pkg/repository/prisma/dbsqlc/models.go+51
- pkg/repository/prisma/dbsqlc/queue.sql+114
- pkg/repository/prisma/dbsqlc/queue.sql.go+308
- pkg/repository/prisma/dbsqlc/schema.sql+18-1
- pkg/repository/prisma/dbsqlc/sqlc.yaml+1
- pkg/repository/prisma/dbsqlc/workers.sql+22
- pkg/repository/prisma/dbsqlc/workers.sql.go+92
- pkg/repository/prisma/dispatcher.go+1-1
- pkg/repository/prisma/event.go+11-10
- pkg/repository/prisma/get_group_key_run.go+3-3
- pkg/repository/prisma/job_run.go+1-1
- pkg/repository/prisma/log.go+2-2
- pkg/repository/prisma/rate_limit.go+1-1
- pkg/repository/prisma/repository.go+2-1
- pkg/repository/prisma/rollback.go-22
- pkg/repository/prisma/sqlchelpers/duration.go+17
- pkg/repository/prisma/sqlchelpers/retry.go+71
- pkg/repository/prisma/sqlchelpers/tx.go+56
- pkg/repository/prisma/sqlchelpers/uuid.go+16
- pkg/repository/prisma/step_run.go+64-181
- pkg/repository/prisma/stream_event.go+3-3
- pkg/repository/prisma/tenant.go+4-4
- pkg/repository/prisma/tenant_alerting.go+1-1
- pkg/repository/prisma/worker.go+2-2
- pkg/repository/prisma/workflow.go+4-4
- pkg/repository/prisma/workflow_run.go+22-19
- pkg/repository/step_run.go+2
- pkg/scheduling/v2/action.go+21
- pkg/scheduling/v2/lease_manager.go+363
- pkg/scheduling/v2/lease_manager_test.go+164
- pkg/scheduling/v2/pool.go+156
- pkg/scheduling/v2/queuer.go+999
- pkg/scheduling/v2/rate_limit.go+372
- pkg/scheduling/v2/rate_limit_test.go+223
- pkg/scheduling/v2/scheduler.go+593
- pkg/scheduling/v2/slot.go+195
- pkg/scheduling/v2/tenant_manager.go+193
- pkg/scheduling/v2/worker.go+73
- pkg/worker/context.go+7-15
- pkg/worker/middleware_test.go+2-2
- prisma/migrations/20241002174554_0_48_2/migration.sql+2
- prisma/migrations/20241009051216_v0_49_3/migration.sql-2
- prisma/migrations/20241014194315_v0_50_0/migration.sql+19
- prisma/schema.prisma+24
- sql/migrations/20241011235145_0.49.4.sql-2
- sql/migrations/20241014194326_v0.50.0.sql+10
- sql/migrations/atlas.sum+2-2
- sql/schema/schema.sql+18-1
0 commit comments