diff options
| -rwxr-xr-x | .rr.yaml | 21 | ||||
| -rw-r--r-- | plugins/server/plugin.go | 4 |
2 files changed, 18 insertions, 7 deletions
@@ -45,11 +45,26 @@ logs: # Workflow and activity mesh service temporal: - address: localhost:7233 activities: num_workers: 4 - codec: proto - debug_level: 2 + # default 0 - no limit + max_jobs: 0 + # default 1 minute + allocate_timeout: 60s + # default 1 minute + destroy_timeout: 60s + # supervisor used to control http workers + supervisor: + # watch_tick defines how often to check the state of the workers (seconds) + watch_tick: 1s + # ttl defines maximum time worker is allowed to live (seconds) + ttl: 0 + # idle_ttl defines maximum duration worker can spend in idle mode after first use. Disabled when 0 (seconds) + idle_ttl: 0 + # exec_ttl defines maximum lifetime per job (seconds) + exec_ttl: 0 + # max_worker_memory limits memory usage per worker (MB) + max_worker_memory: 100 http: # host and port separated by semicolon diff --git a/plugins/server/plugin.go b/plugins/server/plugin.go index 95e593b8..f708b15e 100644 --- a/plugins/server/plugin.go +++ b/plugins/server/plugin.go @@ -90,10 +90,6 @@ func (server *Plugin) CmdFactory(env Env) (func() *exec.Cmd, error) { return nil, errors.E(op, errors.Str("minimum command should be `<executable> <script>")) } - _, err := os.Stat(cmdArgs[1]) - if err != nil { - return nil, errors.E(op, err) - } return func() *exec.Cmd { cmd := exec.Command(cmdArgs[0], cmdArgs[1:]...) //nolint:gosec utils.IsolateProcess(cmd) |