diff --git a/internal/services/runservice/executor/driver/docker.go b/internal/services/runservice/executor/driver/docker.go index 8c3def3..6ad81f0 100644 --- a/internal/services/runservice/executor/driver/docker.go +++ b/internal/services/runservice/executor/driver/docker.go @@ -302,28 +302,6 @@ func podLabelsFromContainer(containerLabels map[string]string) map[string]string return labels } -func (d *DockerDriver) GetPodByID(ctx context.Context, podID string) (Pod, error) { - args := filters.NewArgs() - args.Add(podIDKey, podID) - - containers, err := d.client.ContainerList(ctx, - types.ContainerListOptions{ - Filters: args, - }) - if err != nil { - return nil, err - } - if len(containers) == 0 { - return nil, errors.Errorf("no pod with id %s", podID) - } - - return &DockerPod{ - labels: podLabelsFromContainer(containers[0].Labels), - client: d.client, - containers: containers, - }, nil -} - type DockerPod struct { id string client *client.Client diff --git a/internal/services/runservice/executor/driver/driver.go b/internal/services/runservice/executor/driver/driver.go index bca32ad..1a668f8 100644 --- a/internal/services/runservice/executor/driver/driver.go +++ b/internal/services/runservice/executor/driver/driver.go @@ -45,7 +45,6 @@ type Driver interface { Setup(ctx context.Context) error NewPod(ctx context.Context, podConfig *PodConfig, out io.Writer) (Pod, error) GetPods(ctx context.Context, all bool) ([]Pod, error) - GetPodByID(ctx context.Context, containerID string) (Pod, error) ExecutorGroup(ctx context.Context) (string, error) GetExecutors(ctx context.Context) ([]string, error) }