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

Method StopTask

driver/driver.go:701–710  ·  view source on GitHub ↗

StopTask will not be called if the task has already exited (e.g. onError).

(taskID string, timeout time.Duration, signal string)

Source from the content-addressed store, hash-verified

699
700// StopTask will not be called if the task has already exited (e.g. onError).
701func (d *Driver) StopTask(taskID string, timeout time.Duration, signal string) error {
702 d.logger.Info("StopTask", "id", taskID, "signal", signal)
703 handle, ok := d.tasks.Get(taskID)
704 if !ok {
705 return drivers.ErrTaskNotFound
706 }
707
708 handle.Destroy()
709 return nil
710}
711
712func (d *Driver) DestroyTask(taskID string, force bool) error {
713 d.logger.Info("DestroyTask", "id", taskID)

Callers

nothing calls this directly

Calls 2

GetMethod · 0.80
DestroyMethod · 0.80

Tested by

no test coverage detected