Implementando mecanismo de Schedule

.github/workflows/gh-akf-new-release.yaml

@@ -129,13 +129,13 @@ jobs:
             Download the appropriate binary for your platform, make it executable, and add it to your PATH.
 
             ### Download Client 
-            For more information, visit [AkôFlow Client documentation](https://akoflow.com/docs/).
+            For more information, visit [AkôFlow Client documentation](https://github.com/UFFeScience/akoflow/wiki/).
 
             ### Download Server
-            For more information, visit [AkôFlow Server documentation](https://akoflow.com/docs/).
+            For more information, visit [AkôFlow Server documentation](https://github.com/UFFeScience/akoflow/wiki/).
 
             ## Documentation
-            For more information, visit [AkôFlow documentation](https://akoflow.com/docs/).
+            For more information, visit [AkôFlow documentation](https://github.com/UFFeScience/akoflow/wiki/).
           draft: false
           prerelease: false
           files: |

.gitignore

@@ -9,4 +9,5 @@ releases/bin/*
 *.db
 *.sif
 .env
-resources/
+resources/
+keys/

.vscode/launch.json

@@ -7,10 +7,7 @@
             "request": "launch",
             "mode": "debug",
             "program": "cmd/server/main.go",
-            "env": {
-                "K8S_API_SERVER_HOST": "localhost",
-                "K8S_API_SERVER_TOKEN": "dummy",
-            }
+            "buildFlags": ["-gcflags=all=-N -l"]
         },
         {
             "name": "Launch AkoFlow Client Run",

README.md

@@ -21,10 +21,17 @@ Although initially focused on Kubernetes-based workloads, AkôFlow has evolved t
 
 ⸻
 
-## Maintainers
-* [D.Sc. Daniel de Oliveira — Research Advisor](http://profs.ic.uff.br/~danielcmo/)
-* [Wesley Ferreira - @ovvesley — Maintainer](https://github.com/ovvesley)
-* Raphael Garcia — Maintainer
+## Contributors
+* [D.Sc. Daniel de Oliveira — Research Advisor](http://profs.ic.uff.br/~danielcmo/)  
+* [Wesley Ferreira - @ovvesley — Maintainer - IC/UFF](https://github.com/ovvesley)  
+* Liliane Kunstmann - COPPE/UFRJ
+* Debora Pina - COPPE/UFRJ
+* Raphael Garcia — IC/UFF
+* [Yuri Frota — IC/UFF](http://www.ic.uff.br/~yuri/)  
+* [Marcos Bedo — IC/UFF](https://www.professores.uff.br/marcosbedo/)  
+* [Aline Paes — IC/UFF](http://www.ic.uff.br/~alinepaes/)  
+* [Luan Teylo — INRIA/Université de Bordeaux](https://team.inria.fr/)  
+
 
 ⸻
 

pkg/client/resource/multiple-runtimes/wf-01.yaml

@@ -1,103 +1,117 @@
 name: wf-hello-world-gcp
 spec:
   namespace: "akoflow"
+  runtime: "k8s"
+  schedule: "schedule1"
   storagePolicy:
     storageClassName: "standard"
     storageSize: "32Mi"
     type: distributed
   mountPath: "/data"
   activities:
     - name: "a"
-      memoryLimit: 500Mi
+      memoryLimit: 500Mi    
       cpuLimit: 0.5
-      runtime: "k8s1"
       image: "alpine:3.18"
       run: |
-        echo "Hello World" >> /data/a/output.txt
+        echo "Hello World" >> output.txt
         sleep 5
-        echo "Hello World Again" >> /data/a/output.txt
+        echo "Hello World Again" >> output.txt
         sleep 5
-        echo "Hello World One More Time" >> /data/a/output.txt
+        echo "Hello World One More Time" >> output.txt
 
     - name: "b"
       memoryLimit: 500Mi
       cpuLimit: 0.5
-      runtime: "k8s2"
+      runtime: "k8s"
       image: "alpine:3.18"
       run: |
-        echo "Good Afternoon" >> /data/b/output.txt
+        echo "Good Afternoon" >> output.txt
         sleep 5
-        echo "Good Afternoon Again" >> /data/b/output.txt
+        echo "Good Afternoon Again" >> output.txt
         sleep 5
-        echo "Good Afternoon One More Time" >> /data/b/output.txt
+        echo "Good Afternoon One More Time" >> output.txt
 
     - name: "c"
       memoryLimit: 500Mi
       cpuLimit: 0.5
-      runtime: "k8s1"
+      runtime: "k8s"
       image: "alpine:3.18"
       run: |
-        echo "Goodbye" >> /data/c/output.txt
+        echo "Goodbye" >> output.txt
         sleep 5
-        echo "Goodbye Again" >> /data/c/output.txt
+        echo "Goodbye Again" >> output.txt
         sleep 5
-        echo "Goodbye One More Time" >> /data/c/output.txt
+        echo "Goodbye One More Time" >> output.txt
 
     - name: "d"
       memoryLimit: 500Mi
       cpuLimit: 0.5
-      runtime: "k8s1"
+      runtime: "k8s"
       image: "alpine:3.18"
       run: |
-        echo "Goodbye" >> /data/d/output.txt
+        echo "Goodbye" >> output.txt
+        sleep 5
+        echo "Goodbye Again" >> output.txt
         sleep 5
-        echo "Goodbye Again" >> /data/d/output.txt
+        echo "Goodbye One More Time" >> output.txt
+
+    - name: "e"
+      memoryLimit: 500Mi
+      cpuLimit: 0.5
+      runtime: "k8s"
+      image: "alpine:3.18"
+      run: |
+        echo "Goodbye" >> output.txt
         sleep 5
-        echo "Goodbye One More Time" >> /data/d/output.txt
+        echo "Goodbye Again" >> output.txt
+        sleep 5
+        echo "Goodbye One More Time" >> output.txt
       dependsOn:
         - "a"
         - "b"
         - "c"
+        - "d"
 
-    - name: "e"
+    - name: "f"
       memoryLimit: 500Mi
       cpuLimit: 0.5
-      runtime: "k8s2"
+      runtime: "k8s"
       image: "alpine:3.18"
       run: |
-        echo "Goodbye" >> /data/e/output.txt
+        echo "Goodbye" >> output.txt
         sleep 5
-        echo "Goodbye Again" >> /data/e/output.txt
+        echo "Goodbye Again" >> output.txt
         sleep 5
-        echo "Goodbye One More Time" >> /data/e/output.txt
+        echo "Goodbye One More Time" >> output.txt
       dependsOn:
         - "c"
-    - name: "f"
+    - name: "g"
       memoryLimit: 500Mi
       cpuLimit: 0.5
-      runtime: "k8s2"
+      runtime: "k8s"
       image: "alpine:3.18"
       run: |
-        echo "Goodbye" >> /data/f/output.txt
+        echo "Goodbye" >> output.txt
         sleep 5
-        echo "Goodbye Again" >> /data/f/output.txt
+        echo "Goodbye Again" >> output.txt
         sleep 5
-        echo "Goodbye One More Time" >> /data/f/output.txt
+        echo "Goodbye One More Time" >> output.txt
       dependsOn:
         - "d"
         - "e"
 
-    - name: "g"
+    - name: "h"
       memoryLimit: 500Mi
       cpuLimit: 0.5
-      runtime: "k8s1"
+      runtime: "k8s"
       image: "alpine:3.18"
       run: |
-        echo "Goodbye" >> /data/g/output.txt
+        echo "Goodbye" >> output.txt
         sleep 5
-        echo "Goodbye Again" >> /data/g/output.txt
+        echo "Goodbye Again" >> output.txt
         sleep 5
-        echo "Goodbye One More Time" >> /data/g/output.txt
+        echo "Goodbye One More Time" >> output.txt
         sleep 300
 
       dependsOn:

pkg/client/resource/schedules/wf-01-a00.yaml

@@ -0,0 +1,98 @@
+name: wf-schedule-a
+spec:
+  namespace: "akoflow"
+  runtime: "k8s"
+  schedule: "schedule3"
+  storagePolicy:
+    storageClassName: "local-path"
+    storageSize: "32Mi"
+    type: distributed
+  mountPath: "/export"
+  activities:
+    - name: "activity1"
+      memoryLimit: 1543Mi   # 1343 + 200
+      cpuLimit: 1.0
+      image: "ovvesley/synthetic:alpha1x86"
+      run: |
+        /home/app/bin/synthetic 18763
+
+    - name: "activity2"
+      memoryLimit: 1040Mi   # 840 + 200
+      cpuLimit: 1.0
+      image: "ovvesley/synthetic:alpha1x86"
+      run: |
+        /home/app/bin/synthetic 14836
+
+    - name: "activity3"
+      memoryLimit: 1245Mi   # 1045 + 200
+      cpuLimit: 1.0
+      image: "ovvesley/synthetic:alpha1x86"
+      run: |
+        /home/app/bin/synthetic 16547
+
+    - name: "activity4"
+      memoryLimit: 1202Mi   # 1002 + 200
+      cpuLimit: 1.0
+      image: "ovvesley/synthetic:alpha1x86"
+      run: |
+        /home/app/bin/synthetic 16207
+      dependsOn:
+        - "activity1"
+        - "activity2"
+
+    - name: "activity5"
+      memoryLimit: 1623Mi   # 1423 + 200
+      cpuLimit: 1.0
+      image: "ovvesley/synthetic:alpha1x86"
+      run: |
+        /home/app/bin/synthetic 19311
+      dependsOn:
+        - "activity2"
+        - "activity3"
+
+    - name: "activity6"
+      memoryLimit: 1574Mi   # 1374 + 200
+      cpuLimit: 1.0
+      image: "ovvesley/synthetic:alpha1x86"
+      run: |
+        /home/app/bin/synthetic 18975
+      dependsOn:
+        - "activity4"
+        - "activity5"
+
+    - name: "activity7"
+      memoryLimit: 1750Mi   # 1550 + 200
+      cpuLimit: 1.0
+      image: "ovvesley/synthetic:alpha1x86"
+      run: |
+        /home/app/bin/synthetic 20158
+      dependsOn:
+        - "activity6"
+
+    - name: "activity8"
+      memoryLimit: 1090Mi   # 890 + 200
+      cpuLimit: 1.0
+      image: "ovvesley/synthetic:alpha1x86"
+      run: |
+        /home/app/bin/synthetic 15278
+      dependsOn:
+        - "activity6"
+
+    - name: "activity9"
+      memoryLimit: 1365Mi   # 1165 + 200
+      cpuLimit: 1.0
+      image: "ovvesley/synthetic:alpha1x86"
+      run: |
+        /home/app/bin/synthetic 17474
+      dependsOn:
+        - "activity7"
+        - "activity8"
+
+    - name: "activity10"
+      memoryLimit: 1044Mi   # 844 + 200
+      cpuLimit: 1.0
+      image: "ovvesley/synthetic:alpha1x86"
+      run: |
+        /home/app/bin/synthetic 14871
+      dependsOn:
+        - "activity9"