(taskID string, cmd []string, timeout time.Duration)
| 852 | } |
| 853 | |
| 854 | func (d *Driver) ExecTask(taskID string, cmd []string, timeout time.Duration) (*drivers.ExecTaskResult, error) { |
| 855 | d.logger.Info("ExecTask", "id", taskID) |
| 856 | h, ok := d.tasks.Get(taskID) |
| 857 | if !ok { |
| 858 | return nil, drivers.ErrTaskNotFound |
| 859 | } |
| 860 | |
| 861 | res := drivers.ExecTaskResult{ |
| 862 | Stdout: []byte(fmt.Sprintf("Exec(%q, %q)", h.taskConfig.Name, cmd)), |
| 863 | ExitResult: &drivers.ExitResult{}, |
| 864 | } |
| 865 | return &res, nil |
| 866 | } |
| 867 | |
| 868 | func (d *Driver) Shutdown() { |
| 869 | d.logger.Info("Driver.Shutdown") |