This repository was archived by the owner on Mar 26, 2025. It is now read-only.
1 file changed
+1
-1
lines changed- cmd/hatchet-engine/engine/run.go+384-26
- frontend/docs/pages/home/features/cancellation.mdx+1-1
- frontend/docs/pages/home/features/triggering-runs/cron-trigger.mdx+7-1
- go.mod+3-3
- go.sum+6-6
- internal/msgqueue/msgqueue.go+1
- internal/queueutils/batch.go+34-2
- internal/services/admin/server.go+24-44
- internal/services/controllers/jobs/controller.go+24-39
- internal/services/controllers/jobs/queue.go+20-145
- internal/services/controllers/retention/controller.go+1-1
- internal/services/controllers/workflows/controller.go+2-2
- internal/services/dispatcher/dispatcher.go+135
- internal/services/dispatcher/server.go+67
- internal/services/heartbeat/heartbeater.go-107
- internal/services/partition/partition.go+160-20
- internal/services/scheduler/scheduler.go+419
- internal/services/shared/tasktypes/step.go+9
- internal/services/ticker/ticker.go+1-1
- internal/services/webhooks/webhooks.go+1-1
- pkg/config/loader/debugger.go+87
- pkg/config/loader/loader.go+21-3
- pkg/config/server/server.go+45-10
- pkg/repository/buffer/buffered.go+3-2
- pkg/repository/buffer/bulk_events.go+8-9
- pkg/repository/buffer/config.go+10
- pkg/repository/buffer/queue_step_run.go+204
- pkg/repository/buffer/release_semaphores.go+148
- pkg/repository/buffer/tenant_buffer.go+8-6
- pkg/repository/prisma/db/db_gen.go+20.0k-14.2k
- pkg/repository/prisma/dbsqlc/copyfrom.go+42
- pkg/repository/prisma/dbsqlc/job_runs.sql+1-3
- pkg/repository/prisma/dbsqlc/job_runs.sql.go+4-11
- pkg/repository/prisma/dbsqlc/lease.sql+3-2
- pkg/repository/prisma/dbsqlc/lease.sql.go+6-5
- pkg/repository/prisma/dbsqlc/models.go+13-3
- pkg/repository/prisma/dbsqlc/queue.sql+53-11
- pkg/repository/prisma/dbsqlc/queue.sql.go+63-24
- pkg/repository/prisma/dbsqlc/schema.sql+22
- pkg/repository/prisma/dbsqlc/step_runs.sql+141-18
- pkg/repository/prisma/dbsqlc/step_runs.sql.go+286-18
- pkg/repository/prisma/dbsqlc/tenants.sql+99
- pkg/repository/prisma/dbsqlc/tenants.sql.go+197-5
- pkg/repository/prisma/dbsqlc/workflow_runs.sql+22-9
- pkg/repository/prisma/dbsqlc/workflow_runs.sql.go+75-18
- pkg/repository/prisma/dbsqlc/workflows.sql+24-28
- pkg/repository/prisma/dbsqlc/workflows.sql.go+34-72
- pkg/repository/prisma/repository.go+5-2
- pkg/repository/prisma/sqlchelpers/tx.go+11
- pkg/repository/prisma/step_run.go+124-305
- pkg/repository/prisma/tenant.go+70
- pkg/repository/prisma/worker.go+1-1
- pkg/repository/prisma/workflow.go+39-24
- pkg/repository/prisma/workflow_run.go+36-32
- pkg/repository/step_run.go+2
- pkg/repository/tenant.go+12
- pkg/repository/workflow.go+1-1
- pkg/scheduling/v2/lease_manager.go+53-5
- pkg/scheduling/v2/lease_manager_test.go+3-3
- pkg/scheduling/v2/pool.go+2-2
- pkg/scheduling/v2/queuer.go+230-90
- pkg/scheduling/v2/scheduler.go+232-129
- pkg/scheduling/v2/slot.go+10-3
- prisma/migrations/20241022124201_v0_50_2/migration.sql+19
- prisma/migrations/20241023112223_v0_50_3/migration.sql+5
- prisma/schema.prisma+22
- sql/constraints.sql+16
- sql/migrations/20241018142125_v0.50.1.sql+17
- sql/migrations/20241022124210_v0.50.2.sql+6
- sql/migrations/20241023112235_v0.50.3.sql+30
- sql/migrations/atlas.sum+4-1
- sql/schema/schema.sql+38
0 commit comments