last commit

Author: alon-dotan-starkware

README.md

@@ -1 +1,7 @@
 # simple-python-scheduler
+
+# Deploymet: #
+```
+cd deployment/simple-python-scheduler
+helm upgrade --install  --namespace NAMSPACE_NAME --create-namespace  simple-python-scheduler . -f values.yaml
+```

deployment/simple-python-scheduler/.helmignore

@@ -0,0 +1,23 @@
+# Patterns to ignore when building packages.
+# This supports shell glob matching, relative path matching, and
+# negation (prefixed with !). Only one pattern per line.
+.DS_Store
+# Common VCS dirs
+.git/
+.gitignore
+.bzr/
+.bzrignore
+.hg/
+.hgignore
+.svn/
+# Common backup files
+*.swp
+*.bak
+*.tmp
+*.orig
+*~
+# Various IDEs
+.project
+.idea/
+*.tmproj
+.vscode/

deployment/simple-python-scheduler/Chart.yaml

@@ -0,0 +1,24 @@
+apiVersion: v2
+name: simple-python-scheduler
+description: A Helm chart for Kubernetes
+
+# A chart can be either an 'application' or a 'library' chart.
+#
+# Application charts are a collection of templates that can be packaged into versioned archives
+# to be deployed.
+#
+# Library charts provide useful utilities or functions for the chart developer. They're included as
+# a dependency of application charts to inject those utilities and functions into the rendering
+# pipeline. Library charts do not define any templates and therefore cannot be deployed.
+type: application
+
+# This is the chart version. This version number should be incremented each time you make changes
+# to the chart and its templates, including the app version.
+# Versions are expected to follow Semantic Versioning (https://semver.org/)
+version: 0.1.0
+
+# This is the version number of the application being deployed. This version number should be
+# incremented each time you make changes to the application. Versions are not expected to
+# follow Semantic Versioning. They should reflect the version the application is using.
+# It is recommended to use it with quotes.
+appVersion: "1.16.0"

…/simple-python-scheduler-deployment.yaml …ython-scheduler/templates/deployment.ymldeployment/simple-python-scheduler-deployment.yaml renamed to deployment/simple-python-scheduler/templates/deployment.yml deployment/simple-python-scheduler-deployment.yaml renamed to deployment/simple-python-scheduler/templates/deployment.yml

@@ -2,6 +2,7 @@ apiVersion: apps/v1
 kind: Deployment
 metadata:
   name: simple-python-scheduler
+  namespace: {{ .Release.Namespace }}
 spec:
   replicas: 1
   selector:
@@ -14,4 +15,7 @@ spec:
     spec:
       containers:
       - name: simple-python-scheduler
-        image: simple-python-scheduler:latest
+        image: {{ .Values.image }}
+        env:
+          - name: NAMESPACE
+            value: {{ .Values.monitoredNamespace }}

deployment/rbac.yml …mple-python-scheduler/templates/rbac.ymldeployment/rbac.yml renamed to deployment/simple-python-scheduler/templates/rbac.yml deployment/rbac.yml renamed to deployment/simple-python-scheduler/templates/rbac.yml

@@ -18,7 +18,7 @@ metadata:
 subjects:
   - kind: ServiceAccount
     name: default
-    namespace: simple-python-scheduler
+    namespace: {{ .Release.Namespace }}
 roleRef:
   kind: ClusterRole
   name: simple-python-scheduler

deployment/simple-python-scheduler/values.yaml

@@ -0,0 +1,8 @@
+# Default values for simple-python-scheduler.
+# This is a YAML-formatted file.
+# Declare variables to be passed into your templates.
+
+replicaCount: 1
+
+image: ghcr.io/dotanalon/simple-python-scheduler:latest
+monitoredNamespace: test-ns

src/main.py

@@ -1,6 +1,7 @@
 #!/usr/bin/env python
 
-from os import name
+from nt import environ
+import os
 import time
 import random
 import json
@@ -12,7 +13,7 @@
 batch1 = client.BatchV1Api()
 
 scheduler_name = "simple-python-scheduler"
-NAMESPACE = "test-ns"
+NAMESPACE = os.environ.get("NAMESPACE", "test-ns")
 
 
 def nodes_available():
@@ -47,14 +48,14 @@ def preemption(priority):
 
 
 def get_free_slots(priority):
-    slots = 0
+    slots = len(nodes_available())
     for pod in get_running_pods():
         try:
             pod_priority = pod.metadata.annotations["priority"]
         except:
-            slots += 1
+            pass
         if int(pod_priority) < int(priority):
-            slots += 1
+            slots -= 1
     return slots
 
 

src/resources/example-job.yaml

@@ -15,5 +15,5 @@ spec:
         image: perl:5.34.0
         command: ["perl",  "-Mbignum=bpi", "-wle", "print bpi(2000)"]
       restartPolicy: Never
-  parallelism: 4
+  parallelism: 3
   backoffLimit: 4