diff --git a/packages/client/hmi-client/src/components/workflow/ops/optimize-ciemss/optimize-ciemss-operation.ts b/packages/client/hmi-client/src/components/workflow/ops/optimize-ciemss/optimize-ciemss-operation.ts
index 09192f8243..6412cfeae8 100644
--- a/packages/client/hmi-client/src/components/workflow/ops/optimize-ciemss/optimize-ciemss-operation.ts
+++ b/packages/client/hmi-client/src/components/workflow/ops/optimize-ciemss/optimize-ciemss-operation.ts
@@ -72,6 +72,8 @@ export interface OptimizeCiemssOperationState extends BaseState {
 	optimizedInterventionPolicyId: string;
 	optimizeErrorMessage: { name: string; value: string; traceback: string };
 	simulateErrorMessage: { name: string; value: string; traceback: string };
+	// Intermediate:
+	currentProgress: number; // optimization run's 2 digit %
 }
 
 // This is used as a map between dropdown labels and the inner values used by pyciemss-service.
@@ -150,7 +152,8 @@ export const OptimizeCiemssOperation: Operation = {
 			optimizationRunId: '',
 			optimizedInterventionPolicyId: '',
 			optimizeErrorMessage: { name: '', value: '', traceback: '' },
-			simulateErrorMessage: { name: '', value: '', traceback: '' }
+			simulateErrorMessage: { name: '', value: '', traceback: '' },
+			currentProgress: 0
 		};
 		return init;
 	}
diff --git a/packages/client/hmi-client/src/components/workflow/ops/optimize-ciemss/tera-optimize-ciemss-drilldown.vue b/packages/client/hmi-client/src/components/workflow/ops/optimize-ciemss/tera-optimize-ciemss-drilldown.vue
index 8743a061e2..c2f177c53a 100644
--- a/packages/client/hmi-client/src/components/workflow/ops/optimize-ciemss/tera-optimize-ciemss-drilldown.vue
+++ b/packages/client/hmi-client/src/components/workflow/ops/optimize-ciemss/tera-optimize-ciemss-drilldown.vue
@@ -239,7 +239,6 @@
 		<template #preview>
 			<tera-drilldown-section
 				class="ml-3 mr-3"
-				:is-loading="showSpinner"
 				:class="{ 'failed-run': optimizationResult.success === 'False' ?? 'successful-run' }"
 			>
 				<template #header-controls-left v-if="optimizedInterventionPolicy?.name">
@@ -254,10 +253,18 @@
 						@click="showSaveInterventionPolicy = true"
 					/>
 				</template>
-
+				<tera-progress-spinner v-if="showSpinner" :font-size="2" is-centered style="height: 100%">
+					<div v-if="node.state.inProgressOptimizeId !== ''">
+						{{ props.node.state.currentProgress }}% of maximum iterations complete
+					</div>
+					<div v-else>Optimize complete. Running simulations</div>
+				</tera-progress-spinner>
 				<tera-operator-output-summary v-if="node.state.summaryId && !showSpinner" :summary-id="node.state.summaryId" />
 				<!-- Optimize result.json display: -->
-				<div v-if="optimizationResult && displayOptimizationResultMessage" class="result-message-grid mt-2 mb-2">
+				<div
+					v-if="optimizationResult && displayOptimizationResultMessage && !showSpinner"
+					class="result-message-grid mt-2 mb-2"
+				>
 					<span class="flex flex-row">
 						<p class="mt-2">For debugging</p>
 						<Button
@@ -275,6 +282,7 @@
 					</div>
 				</div>
 				<SelectButton
+					v-if="!showSpinner"
 					:model-value="outputViewSelection"
 					@change="if ($event.value) outputViewSelection = $event.value;"
 					:options="outputViewOptions"
@@ -288,7 +296,7 @@
 				</SelectButton>
 				<tera-notebook-error v-bind="node.state.optimizeErrorMessage" />
 				<tera-notebook-error v-bind="node.state.simulateErrorMessage" />
-				<template v-if="runResults[knobs.postForecastRunId] && runResults[knobs.preForecastRunId]">
+				<template v-if="runResults[knobs.postForecastRunId] && runResults[knobs.preForecastRunId] && !showSpinner">
 					<section v-if="outputViewSelection === OutputView.Charts" ref="outputPanel">
 						<Accordion multiple :active-index="[0, 1, 2]">
 							<AccordionTab header="Success criteria">
@@ -379,6 +387,7 @@ import TeraDrilldownSection from '@/components/drilldown/tera-drilldown-section.
 import TeraSaveDatasetFromSimulation from '@/components/dataset/tera-save-dataset-from-simulation.vue';
 import TeraPyciemssCancelButton from '@/components/pyciemss/tera-pyciemss-cancel-button.vue';
 import TeraOperatorOutputSummary from '@/components/operator/tera-operator-output-summary.vue';
+import TeraProgressSpinner from '@/components/widgets/tera-progress-spinner.vue';
 import { getUnitsFromModelParts, getModelByModelConfigurationId } from '@/services/model';
 import { createModelConfiguration, getModelConfigurationById } from '@/services/model-configurations';
 import {
@@ -1119,6 +1128,17 @@ watch(
 	padding: var(--gap-1) var(--gap);
 	gap: var(--gap-2);
 }
+
+.spinner-message {
+	align-items: center;
+	align-self: center;
+	display: flex;
+	flex-direction: column;
+	gap: var(--gap-2);
+	margin-top: 15rem;
+	text-align: center;
+}
+
 .info-circle {
 	color: var(--text-color-secondary);
 	font-size: var(--font-caption);
diff --git a/packages/client/hmi-client/src/components/workflow/ops/optimize-ciemss/tera-optimize-ciemss-node.vue b/packages/client/hmi-client/src/components/workflow/ops/optimize-ciemss/tera-optimize-ciemss-node.vue
index 592ceca61d..d7ec7ef71a 100644
--- a/packages/client/hmi-client/src/components/workflow/ops/optimize-ciemss/tera-optimize-ciemss-node.vue
+++ b/packages/client/hmi-client/src/components/workflow/ops/optimize-ciemss/tera-optimize-ciemss-node.vue
@@ -4,7 +4,14 @@
 			<template v-if="!node.inputs[0].value"> Attach a model configuration </template>
 		</tera-operator-placeholder>
 		<template v-if="node.inputs[0].value">
-			<tera-progress-spinner v-if="showSpinner" :font-size="2" is-centered style="height: 100%" />
+			<div v-if="showSpinner">
+				<div v-if="node.state.inProgressOptimizeId !== ''">
+					{{ props.node.state.currentProgress }}% of maximum iterations complete
+				</div>
+				<div v-else>Optimize complete. Running simulations</div>
+				<tera-progress-spinner :font-size="2" is-centered style="height: 100%" />
+			</div>
+
 			<div v-if="!showSpinner && runResults">
 				<template v-for="(_, index) of node.state.selectedSimulationVariables" :key="index">
 					<vega-chart :visualization-spec="preparedCharts[index]" :are-embed-actions-visible="false" />
@@ -33,7 +40,7 @@ import {
 	parsePyCiemssMap
 } from '@/services/models/simulation-service';
 import { nodeMetadata, nodeOutputLabel } from '@/components/workflow/util';
-import { SimulationRequest, InterventionPolicy } from '@/types/Types';
+import { SimulationRequest, InterventionPolicy, Simulation, CiemssOptimizeStatusUpdate } from '@/types/Types';
 import { createLLMSummary } from '@/services/summary-service';
 import VegaChart from '@/components/widgets/VegaChart.vue';
 import { createForecastChart } from '@/services/charts';
@@ -74,7 +81,19 @@ const pollResult = async (runId: string) => {
 	poller
 		.setInterval(5000)
 		.setThreshold(100)
-		.setPollAction(async () => pollAction(runId));
+		.setPollAction(async () => pollAction(runId))
+		.setProgressAction((data: Simulation) => {
+			if (runId === props.node.state.inProgressOptimizeId && data.updates.length > 0) {
+				const checkpointData = _.first(data.updates)?.data as CiemssOptimizeStatusUpdate;
+				if (checkpointData) {
+					const state = _.cloneDeep(props.node.state);
+					state.currentProgress = +((100 * checkpointData.progress) / checkpointData.totalPossibleIterations).toFixed(
+						2
+					);
+					emit('update-state', state);
+				}
+			}
+		});
 
 	const pollerResults = await poller.start();
 
@@ -234,6 +253,7 @@ Provide a consis summary in 100 words or less.
 			state.preForecastRunId = preSimId;
 			state.inProgressPostForecastId = '';
 			state.postForecastRunId = postSimId;
+			state.currentProgress = 0;
 			emit('update-state', state);
 
 			const datasetName = `Forecast run ${state.postForecastRunId}`;
@@ -281,6 +301,7 @@ Provide a consis summary in 100 words or less.
 			state.inProgressOptimizeId = '';
 			state.inProgressPreForecastId = '';
 			state.inProgressPostForecastId = '';
+			state.currentProgress = 0;
 			emit('update-state', state);
 		}
 	},
diff --git a/packages/client/hmi-client/src/types/Types.ts b/packages/client/hmi-client/src/types/Types.ts
index a64b85630f..da93178580 100644
--- a/packages/client/hmi-client/src/types/Types.ts
+++ b/packages/client/hmi-client/src/types/Types.ts
@@ -553,12 +553,6 @@ export interface CalibrationRequestCiemss {
     engine: string;
 }
 
-export interface CiemssStatusUpdate {
-    loss: number;
-    progress: number;
-    jobId: string;
-}
-
 export interface EnsembleCalibrationCiemssRequest {
     modelConfigs: EnsembleModelConfigs[];
     dataset: DatasetLocation;
@@ -672,6 +666,21 @@ export interface TimeSpan {
     end: number;
 }
 
+export interface CiemssCalibrateStatusUpdate extends CiemssStatusUpdate {
+    loss: number;
+}
+
+export interface CiemssOptimizeStatusUpdate extends CiemssStatusUpdate {
+    currentResults: number[];
+    totalPossibleIterations: number;
+}
+
+export interface CiemssStatusUpdate {
+    jobId: string;
+    progress: number;
+    type: CiemssStatusType;
+}
+
 export interface TaskResponse {
     id: string;
     script: string;
@@ -1026,6 +1035,11 @@ export enum EvaluationScenarioStatus {
     Stopped = "STOPPED",
 }
 
+export enum CiemssStatusType {
+    Optimize = "optimize",
+    Calibrate = "calibrate",
+}
+
 export enum TaskStatus {
     Queued = "QUEUED",
     Running = "RUNNING",
diff --git a/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/statusupdates/CiemssCalibrateStatusUpdate.java b/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/statusupdates/CiemssCalibrateStatusUpdate.java
new file mode 100644
index 0000000000..f91fd50127
--- /dev/null
+++ b/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/statusupdates/CiemssCalibrateStatusUpdate.java
@@ -0,0 +1,11 @@
+package software.uncharted.terarium.hmiserver.models.simulationservice.statusupdates;
+
+import lombok.Data;
+import software.uncharted.terarium.hmiserver.annotations.TSModel;
+
+@Data
+@TSModel
+public class CiemssCalibrateStatusUpdate extends CiemssStatusUpdate {
+
+	private Number loss;
+}
diff --git a/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/statusupdates/CiemssOptimizeStatusUpdate.java b/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/statusupdates/CiemssOptimizeStatusUpdate.java
new file mode 100644
index 0000000000..a40169efb7
--- /dev/null
+++ b/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/statusupdates/CiemssOptimizeStatusUpdate.java
@@ -0,0 +1,26 @@
+package software.uncharted.terarium.hmiserver.models.simulationservice.statusupdates;
+
+import com.fasterxml.jackson.annotation.JsonAlias;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import java.util.List;
+import lombok.Data;
+import software.uncharted.terarium.hmiserver.annotations.TSModel;
+
+@Data
+@TSModel
+public class CiemssOptimizeStatusUpdate extends CiemssStatusUpdate {
+
+	@JsonAlias("current_results")
+	private List<Number> currentResults;
+
+	@JsonAlias("total_possible_iterations")
+	private Number totalPossibleIterations;
+
+	@JsonIgnore
+	public JsonNode getDataToPersist() {
+		final ObjectMapper mapper = new ObjectMapper();
+		return mapper.valueToTree(this);
+	}
+}
diff --git a/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/statusupdates/CiemssStatusType.java b/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/statusupdates/CiemssStatusType.java
new file mode 100644
index 0000000000..f80b6f8bf8
--- /dev/null
+++ b/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/statusupdates/CiemssStatusType.java
@@ -0,0 +1,22 @@
+package software.uncharted.terarium.hmiserver.models.simulationservice.statusupdates;
+
+import com.fasterxml.jackson.annotation.JsonValue;
+import software.uncharted.terarium.hmiserver.annotations.TSModel;
+
+@TSModel
+public enum CiemssStatusType {
+	OPTIMIZE("optimize"),
+	CALIBRATE("calibrate");
+
+	public final String type;
+
+	CiemssStatusType(final String type) {
+		this.type = type;
+	}
+
+	@Override
+	@JsonValue
+	public String toString() {
+		return type;
+	}
+}
diff --git a/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/CiemssStatusUpdate.java b/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/statusupdates/CiemssStatusUpdate.java
similarity index 85%
rename from packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/CiemssStatusUpdate.java
rename to packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/statusupdates/CiemssStatusUpdate.java
index 988f75aeda..2ebecda1fe 100644
--- a/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/CiemssStatusUpdate.java
+++ b/packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/simulationservice/statusupdates/CiemssStatusUpdate.java
@@ -1,4 +1,4 @@
-package software.uncharted.terarium.hmiserver.models.simulationservice;
+package software.uncharted.terarium.hmiserver.models.simulationservice.statusupdates;
 
 import com.fasterxml.jackson.annotation.JsonAlias;
 import com.fasterxml.jackson.annotation.JsonIgnore;
@@ -9,14 +9,14 @@
 
 @Data
 @TSModel
-public class CiemssStatusUpdate {
+public abstract class CiemssStatusUpdate {
 
-	private Number loss;
+	@JsonAlias("job_id")
+	private String jobId;
 
 	private Number progress;
 
-	@JsonAlias("job_id")
-	private String jobId;
+	private CiemssStatusType type;
 
 	@JsonIgnore
 	public JsonNode getDataToPersist() {
diff --git a/packages/server/src/main/java/software/uncharted/terarium/hmiserver/service/SimulationEventService.java b/packages/server/src/main/java/software/uncharted/terarium/hmiserver/service/SimulationEventService.java
index 33fb2eb6ac..0039683797 100644
--- a/packages/server/src/main/java/software/uncharted/terarium/hmiserver/service/SimulationEventService.java
+++ b/packages/server/src/main/java/software/uncharted/terarium/hmiserver/service/SimulationEventService.java
@@ -1,5 +1,6 @@
 package software.uncharted.terarium.hmiserver.service;
 
+import com.fasterxml.jackson.databind.JsonNode;
 import com.rabbitmq.client.Channel;
 import jakarta.annotation.PostConstruct;
 import java.io.IOException;
@@ -26,8 +27,11 @@
 import software.uncharted.terarium.hmiserver.models.ClientEventType;
 import software.uncharted.terarium.hmiserver.models.User;
 import software.uncharted.terarium.hmiserver.models.dataservice.simulation.SimulationUpdate;
-import software.uncharted.terarium.hmiserver.models.simulationservice.CiemssStatusUpdate;
 import software.uncharted.terarium.hmiserver.models.simulationservice.ScimlStatusUpdate;
+import software.uncharted.terarium.hmiserver.models.simulationservice.statusupdates.CiemssCalibrateStatusUpdate;
+import software.uncharted.terarium.hmiserver.models.simulationservice.statusupdates.CiemssOptimizeStatusUpdate;
+import software.uncharted.terarium.hmiserver.models.simulationservice.statusupdates.CiemssStatusType;
+import software.uncharted.terarium.hmiserver.models.simulationservice.statusupdates.CiemssStatusUpdate;
 import software.uncharted.terarium.hmiserver.service.data.SimulationService;
 import software.uncharted.terarium.hmiserver.utils.rebac.Schema;
 
@@ -151,11 +155,30 @@ private void onScimlAllInstanceReceive(final Message message) {
 
 	@RabbitListener(queues = "${terarium.simulation-status}", concurrency = "1")
 	private void onPyciemssOneInstanceReceives(final Message message, final Channel channel) throws IOException {
-		final CiemssStatusUpdate update = ClientEventService.decodeMessage(message, CiemssStatusUpdate.class);
-		if (update == null) {
+		// Parse message to get message type:
+		final String updateType = (ClientEventService.decodeMessage(message, JsonNode.class)).get("type").asText();
+		if (updateType.equals(CiemssStatusType.OPTIMIZE.toString())) {
+			final CiemssOptimizeStatusUpdate update = ClientEventService.decodeMessage(
+				message,
+				CiemssOptimizeStatusUpdate.class
+			);
+			updateAndSendPyciemssMessage(message, update);
+		} else if (updateType.equals(CiemssStatusType.CALIBRATE.toString())) {
+			final CiemssCalibrateStatusUpdate update = ClientEventService.decodeMessage(
+				message,
+				CiemssCalibrateStatusUpdate.class
+			);
+			updateAndSendPyciemssMessage(message, update);
+		} else {
+			log.error("message in simulation-status with unknown type: " + updateType);
 			return;
 		}
+	}
 
+	private void updateAndSendPyciemssMessage(final Message message, final CiemssStatusUpdate update) {
+		if (update == null) {
+			return;
+		}
 		try {
 			final SimulationUpdate simulationUpdate = new SimulationUpdate();
 			simulationUpdate.setData(update.getDataToPersist());
@@ -193,26 +216,45 @@ private void onPyciemssOneInstanceReceives(final Message message, final Channel
 	)
 	private void onPyciemssAllInstanceReceive(final Message message) {
 		try {
-			final CiemssStatusUpdate update = ClientEventService.decodeMessage(message, CiemssStatusUpdate.class);
-			if (update == null) {
+			// Parse message to get message type:
+			final String updateType = (ClientEventService.decodeMessage(message, JsonNode.class)).get("type").asText();
+			if (updateType.equals(CiemssStatusType.OPTIMIZE.toString())) {
+				final CiemssOptimizeStatusUpdate update = ClientEventService.decodeMessage(
+					message,
+					CiemssOptimizeStatusUpdate.class
+				);
+				passPyciemssToUser(update);
+			} else if (updateType.equals(CiemssStatusType.CALIBRATE.toString())) {
+				final CiemssCalibrateStatusUpdate update = ClientEventService.decodeMessage(
+					message,
+					CiemssCalibrateStatusUpdate.class
+				);
+				passPyciemssToUser(update);
+			} else {
+				log.error("message in simulation-status with unknown type: " + updateType);
 				return;
 			}
-
-			final ClientEvent<CiemssStatusUpdate> status = ClientEvent.<CiemssStatusUpdate>builder()
-				.type(ClientEventType.SIMULATION_PYCIEMSS)
-				.data(update)
-				.build();
-
-			final String id = update.getJobId();
-			if (simulationIdToUserIds.containsKey(id)) {
-				simulationIdToUserIds
-					.get(id)
-					.forEach(userId -> {
-						clientEventService.sendToUser(status, userId);
-					});
-			}
 		} catch (final Exception e) {
 			log.error("Error processing event", e);
 		}
 	}
+
+	private void passPyciemssToUser(final CiemssStatusUpdate update) {
+		if (update == null) {
+			return;
+		}
+		final ClientEvent<CiemssStatusUpdate> status = ClientEvent.<CiemssStatusUpdate>builder()
+			.type(ClientEventType.SIMULATION_PYCIEMSS)
+			.data(update)
+			.build();
+
+		final String id = update.getJobId();
+		if (simulationIdToUserIds.containsKey(id)) {
+			simulationIdToUserIds
+				.get(id)
+				.forEach(userId -> {
+					clientEventService.sendToUser(status, userId);
+				});
+		}
+	}
 }