MCPcopy Create free account
hub / github.com/actiontech/dtle / resumeTask

Method resumeTask

driver/handle.go:117–125  ·  view source on GitHub ↗
(d *Driver)

Source from the content-addressed store, hash-verified

115}
116
117func (h *taskHandle) resumeTask(d *Driver) error {
118 var err error
119 h.runner, err = h.NewRunner(d)
120 if err != nil {
121 return err
122 }
123 go h.runner.Run()
124 return nil
125}
126
127func (h *taskHandle) run(d *Driver) {
128 h.stateLock.Lock()

Callers 2

runMethod · 0.95
SignalTaskMethod · 0.80

Calls 2

NewRunnerMethod · 0.95
RunMethod · 0.65

Tested by

no test coverage detected