Browse Source

Merge pull request #37280 from Microsoft/jjh/fixbuildersources

Don't fail to start daemon if builder source is not available
Tõnis Tiigi 7 years ago
parent
commit
d17b78bdfe
1 changed files with 13 additions and 11 deletions
  1. 13 11
      builder/builder-next/worker/worker.go

+ 13 - 11
builder/builder-next/worker/worker.go

@@ -37,6 +37,7 @@ import (
 	digest "github.com/opencontainers/go-digest"
 	digest "github.com/opencontainers/go-digest"
 	ocispec "github.com/opencontainers/image-spec/specs-go/v1"
 	ocispec "github.com/opencontainers/image-spec/specs-go/v1"
 	"github.com/pkg/errors"
 	"github.com/pkg/errors"
+	"github.com/sirupsen/logrus"
 )
 )
 
 
 // Opt defines a structure for creating a worker.
 // Opt defines a structure for creating a worker.
@@ -77,32 +78,33 @@ func NewWorker(opt Opt) (*Worker, error) {
 		CacheAccessor: cm,
 		CacheAccessor: cm,
 		MetadataStore: opt.MetadataStore,
 		MetadataStore: opt.MetadataStore,
 	})
 	})
-	if err != nil {
-		return nil, err
+	if err == nil {
+		sm.Register(gs)
+	} else {
+		logrus.Warnf("Could not register builder git source: %s", err)
 	}
 	}
 
 
-	sm.Register(gs)
-
 	hs, err := http.NewSource(http.Opt{
 	hs, err := http.NewSource(http.Opt{
 		CacheAccessor: cm,
 		CacheAccessor: cm,
 		MetadataStore: opt.MetadataStore,
 		MetadataStore: opt.MetadataStore,
 		Transport:     opt.Transport,
 		Transport:     opt.Transport,
 	})
 	})
-	if err != nil {
-		return nil, err
+	if err == nil {
+		sm.Register(hs)
+	} else {
+		logrus.Warnf("Could not register builder http source: %s", err)
 	}
 	}
 
 
-	sm.Register(hs)
-
 	ss, err := local.NewSource(local.Opt{
 	ss, err := local.NewSource(local.Opt{
 		SessionManager: opt.SessionManager,
 		SessionManager: opt.SessionManager,
 		CacheAccessor:  cm,
 		CacheAccessor:  cm,
 		MetadataStore:  opt.MetadataStore,
 		MetadataStore:  opt.MetadataStore,
 	})
 	})
-	if err != nil {
-		return nil, err
+	if err == nil {
+		sm.Register(ss)
+	} else {
+		logrus.Warnf("Could not register builder local source: %s", err)
 	}
 	}
-	sm.Register(ss)
 
 
 	return &Worker{
 	return &Worker{
 		Opt:           opt,
 		Opt:           opt,