Additonal Debugging

runtime/kubernetes/kubernetes.go

@@ -256,7 +256,6 @@ func (k *kubernetes) run(events <-chan runtime.Event) {
 					// update build time annotation
 					if service.Spec.Template.Metadata.Annotations == nil {
 						service.Spec.Template.Metadata.Annotations = make(map[string]string)
-
 					}
 
 					// update the build time
@@ -351,6 +350,7 @@ func (k *kubeStream) Stop() error {
 
 // Creates a service
 func (k *kubernetes) Create(s *runtime.Service, opts ...runtime.CreateOption) error {
+	fmt.Println("KUBECTL CREATE")
 	k.Lock()
 	defer k.Unlock()
 

runtime/kubernetes/service.go

@@ -27,6 +27,8 @@ func parseError(err error) *api.Status {
 }
 
 func newService(s *runtime.Service, c runtime.CreateOptions) *service {
+	fmt.Println("KUBECTL newService")
+
 	// use pre-formatted name/version
 	name := client.Format(s.Name)
 	version := client.Format(s.Version)