wip

Signed-off-by: Yuji Ito <llamerada.jp@gmail.com>
llamerada-jp · Feb 4, 2023 · 7b3f684 · 7b3f684
1 parent 959cd00
commit 7b3f684
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/agent/core/pod.go b/agent/core/pod.go
@@ -22,7 +22,6 @@ func NewPod(uuid string) *PodImpl {
 func (p *PodImpl) Update(ctx context.Context, colonio colonio.Colonio) (bool, error) {
 	log.Println("update", p.uuid)
 	key := string(ResourceTypePod) + "/" + p.uuid
-	// TODO colonio has a bug ? that the `Get`` method is blocked when it used in cb?
 	v, err := colonio.KvsGet(key)
 	if err != nil {
 		return false, err

diff --git a/agent/core/system.go b/agent/core/system.go
@@ -103,7 +103,7 @@ func (sys *System) dealResources() error {
 		}
 		resourceEntry := strings.Split(key, "/")
 		if len(resourceEntry) != 2 {
-			return fmt.Errorf("local value key is not supported format", key)
+			return fmt.Errorf("local value key is not supported format:%s", key)
 		}
 		resources = append(resources, struct {
 			resourceType ResourceType
@@ -137,7 +137,7 @@ func (sys *System) dealResource(t ResourceType, js string) error {
 		}
 
 	default:
-		log.Printf("debug unhandled resource %s", string(t))
+		log.Printf("debug unhandled resource:%s", string(t))
 	}
 	return nil
 }
@@ -153,7 +153,7 @@ func (sys *System) schedulePod(pod *Pod) error {
 		return err
 
 	default:
-		return fmt.Errorf("Unsupported scheduling policy:%s", pod.Spec.Scheduler.Type)
+		return fmt.Errorf("unsupported scheduling policy:%s", pod.Spec.Scheduler.Type)
 	}
 }