Prepare calibrated Montage campaign examples

Author: ovvesley

connections/plafrim-execution-environment.yaml

@@ -19,7 +19,7 @@ connections:
     type: ssh
     endpoint: plafrim
     username: wferreir
-    credentialRef: file:/app/storage/credentials/ssh/plafrim-engine
+    credentialRef: file:storage/credentials/ssh/plafrim-engine
     configuration:
       scheduler: slurm
       port: 22

real/montage-cloud-local/README.md

@@ -13,9 +13,14 @@ needed to preserve these commands. The SIF is an additional representation for
 environments that use Apptainer. Docker workers use the pinned OCI image.
 
 `reference-runtimes.csv` is a historical profile measured on `c3d-standard-16`.
-Its times are **not** measurements on `e2-medium` or the local resource. The
-imported plan's predicted time and cost are illustrative metadata, not a
-calibrated forecast or an observed result.
+Each workflow activity carries its corresponding value as a deterministic
+`simulation.durationSeconds` profile, so planning and SimGrid use the measured
+duration of that specific activity rather than a stage-wide default. The source
+timestamps have one-second resolution; the single zero-second observation is
+represented as one second so that every schedulable activity has a positive
+duration. These times are **not** measurements on `e2-medium` or the local
+resource. The imported plan's predicted time and cost are illustrative metadata,
+not a calibrated forecast or an observed result.
 
 ## Requirements
 
@@ -67,8 +72,8 @@ sh "$base/submit-run.sh" montage-58-four-vm-local-050d-run-v1
 Set `AKOFLOW_SSH_CIDR` to the daemon's approved public egress address before
 creating capacity targets. The target uses the connected environment's project,
 the catalog's `e2-medium` offering, a catalog Ubuntu `amd64` image, and a
-30 GiB balanced boot disk. The scope references `gcp-environment-initial`
-and `local-environment-initial`. If the daemon's egress IP changes, update the
+30 GiB balanced boot disk. The scope references `gcp-environment-v1`
+and `local-environment-v1`. If the daemon's egress IP changes, update the
 target's SSH source range before running; the current script rejects existing
 targets with a different SSH range, machine type, project, instance limit, or
 lifecycle.

real/montage-cloud-local/generate.rb

@@ -14,7 +14,12 @@
 abort 'source image does not match the pinned Montage release' unless source.fetch('spec').fetch('image') == 'ovvesley/akoflow-wf-montage:050d'
 original = source.fetch('spec').fetch('activities')
 runtimes = CSV.read(File.join(ROOT, 'reference-runtimes.csv'), headers: true)
-seconds = runtimes.to_h { |row| [row.fetch('activity_id'), row.fetch('duration_seconds').to_f] }
+# The source timestamps have one-second resolution. One activity completed
+# within the same timestamp second; model it as one second instead of a zero
+# duration, which is not a meaningful schedulable task.
+seconds = runtimes.to_h do |row|
+  [row.fetch('activity_id'), [row.fetch('duration_seconds').to_f, 1.0].max]
+end
 abort 'expected 58 distinct activities with reference runtimes' unless original.length == 58 && original.map { |a| a.fetch('name') }.uniq.length == 58 && (original.map { |a| a['name'] } - seconds.keys).empty?
 
 def output_files(command)
@@ -60,7 +65,14 @@ def output_files(command)
   { 'name' => activity['name'], 'runtime' => runtime, 'run' => command,
     'workspaceSeedPath' => '/akoflow-wfa-shared',
     'cpuLimit' => activity.fetch('cpuLimit'), 'memoryLimit' => activity.fetch('memoryLimit'),
-    'dependsOn' => activity.fetch('dependsOn', []) }
+    'dependsOn' => activity.fetch('dependsOn', []),
+    # Preserve the per-activity duration observed in the completed Montage
+    # reference run. Planning and SimGrid use this deterministic baseline;
+    # real execution still records its own observed duration independently.
+    'simulation' => {
+      'model' => 'deterministic',
+      'durationSeconds' => seconds.fetch(activity.fetch('name'))
+    } }
 end
 
 workflow = { 'name' => NAME, 'spec' => { 'namespace' => 'showcase', 'image' => IMAGE,

real/montage-cloud-local/plan.json

@@ -9,7 +9,7 @@
     "algorithmVersion": "1",
     "objective": "custom",
     "predicted": {
-      "makespanSeconds": 12577.0,
+      "makespanSeconds": 12578.0,
       "cost": 0.183961,
       "feasible": true
     },

real/montage-cloud-local/scope.json

@@ -2,5 +2,5 @@
   "id": "montage-58-four-vm-local-050d-gcp-scope-v1",
   "name": "Montage 58 four GCP e2-medium machines and local",
   "networkTopologyId": "montage-58-four-vm-local-050d-gcp-network-v1",
-  "environmentVersionIds": ["gcp-environment-initial", "local-environment-initial"]
+  "environmentVersionIds": ["gcp-environment-v1", "local-environment-v1"]
 }