mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
## What changed? - Merge PR combining the previous PRs: #8164, #8165, #8166, #8167, #8168, #8169 ## Why? - All of those PRs are interdependent and cannot be merged individually cleanly. Sending a single merge commit PR to be merged to main. ## How did you test it? - [ ] built - [ ] run locally and tested manually - [ ] covered by existing tests - [ ] added new unit test(s) - [ ] added new functional test(s) ## Potential risks - It's still disabled.
24 lines
459 B
Go
24 lines
459 B
Go
package scheduler
|
|
|
|
import (
|
|
"go.temporal.io/server/chasm"
|
|
"go.uber.org/fx"
|
|
)
|
|
|
|
func Register(
|
|
registry *chasm.Registry,
|
|
library *Library,
|
|
) error {
|
|
return registry.Register(library)
|
|
}
|
|
|
|
var Module = fx.Module(
|
|
"chasm.lib.scheduler",
|
|
fx.Provide(NewGeneratorTaskExecutor),
|
|
fx.Provide(NewInvokerExecuteTaskExecutor),
|
|
fx.Provide(NewInvokerProcessBufferTaskExecutor),
|
|
fx.Provide(NewBackfillerTaskExecutor),
|
|
fx.Provide(NewLibrary),
|
|
fx.Invoke(Register),
|
|
)
|