diff --git a/docker-compose.yaml b/docker-compose.yaml index 9a6deef..4405755 100644 --- a/docker-compose.yaml +++ b/docker-compose.yaml @@ -26,8 +26,8 @@ services: - "8222" - "--store=memory" - "--cluster_id=faas-cluster" - ports: - - "127.0.0.1:8222:8222" + # ports: + # - "127.0.0.1:8222:8222" prometheus: image: docker.io/prom/prometheus:v2.14.0 diff --git a/pkg/provider/handlers/deploy.go b/pkg/provider/handlers/deploy.go index 0eee4cc..098031e 100644 --- a/pkg/provider/handlers/deploy.go +++ b/pkg/provider/handlers/deploy.go @@ -128,7 +128,6 @@ func deploy(ctx context.Context, req types.FunctionDeployment, client *container func createTask(ctx context.Context, client *containerd.Client, container containerd.Container, cni gocni.CNI) error { name := container.ID() - // task, taskErr := container.NewTask(ctx, cio.NewCreator(cio.WithStdio)) task, taskErr := container.NewTask(ctx, cio.BinaryIO("/usr/local/bin/faasd", nil)) diff --git a/pkg/supervisor.go b/pkg/supervisor.go index 5977f3f..e2695a6 100644 --- a/pkg/supervisor.go +++ b/pkg/supervisor.go @@ -180,10 +180,10 @@ func (s *Supervisor) Start(svcs []Service) error { log.Printf("Created container: %s\n", newContainer.ID()) - task, err := newContainer.NewTask(ctx, cio.NewCreator(cio.WithStdio)) - if err != nil { + task, taskErr := newContainer.NewTask(ctx, cio.BinaryIO("/usr/local/bin/faasd", nil)) + if taskErr != nil { log.Printf("Error creating task: %s\n", err) - return err + return taskErr } labels := map[string]string{}