opencode/yao
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge pull request #438 from trheyi/main

Browse source 
[add] yao run command task support
This commit is contained in:
Max 2023-06-09 00:08:04 +08:00 • committed by GitHub
commit e53133d0e8
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
cmd/run.go
View file

@ -13,7 +13,9 @@ import (
"github.com/yaoapp/kun/utils" "github.com/yaoapp/kun/utils"
"github.com/yaoapp/yao/config" "github.com/yaoapp/yao/config"
"github.com/yaoapp/yao/engine" "github.com/yaoapp/yao/engine"
ischedule "github.com/yaoapp/yao/schedule"
"github.com/yaoapp/yao/share" "github.com/yaoapp/yao/share"
itask "github.com/yaoapp/yao/task"
) )
var runSilent = false var runSilent = false
@ -25,6 +27,7 @@ var runCmd = &cobra.Command{
Run: func(cmd *cobra.Command, args []string) { Run: func(cmd *cobra.Command, args []string) {
defer share.SessionStop() defer share.SessionStop()
defer plugin.KillAll() defer plugin.KillAll()
defer func() { defer func() {
err := exception.Catch(recover()) err := exception.Catch(recover())
if err != nil { if err != nil {
@ -103,6 +106,14 @@ var runCmd = &cobra.Command{
} }
// Start Tasks
itask.Start()
defer itask.Stop()
// Start Schedules
ischedule.Start()
defer ischedule.Stop()
process := process.New(name, pargs...) process := process.New(name, pargs...)
res, err := process.Exec() res, err := process.Exec()
if err != nil { if err != nil {