[O2B-1418] Improve runs start/stop extraction from kafka

AliceO2Group · Dec 16, 2024 · 2b73920 · 2b73920
1 parent 5dafb0e
commit 2b73920
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/server/kafka/AliEcsSynchronizer.js b/lib/server/kafka/AliEcsSynchronizer.js
@@ -72,10 +72,10 @@ class AliEcsSynchronizer {
 
         this.ecsRunConsumer = new AliEcsEventMessagesConsumer(kafkaClient, RUN_CONSUMER_GROUP, RUN_TOPICS);
         this.ecsRunConsumer.onMessageReceived(async (eventMessage) => {
-            const { timestamp, runEvent: { environmentId, runNumber, state, transition, lastRequestUser } } = eventMessage;
+            const { timestamp, runEvent: { environmentId, runNumber, transition, lastRequestUser } } = eventMessage;
             const { externalId: externalUserId, name: userName } = lastRequestUser ?? {};
 
-            if (state === 'CONFIGURED' && transition === 'START_ACTIVITY') {
+            if (transition === 'START_ACTIVITY') {
                 runService
                     .createOrUpdate(
                         runNumber,
@@ -86,7 +86,7 @@ class AliEcsSynchronizer {
                     .catch((error) => this._logger.errorMessage(`Failed to save run start for ${runNumber}: ${error.message}`));
             }
 
-            if (state === 'RUNNING' && transition === 'STOP_ACTIVITY') {
+            if (transition === 'STOP_ACTIVITY' || transition === 'GO_ERROR') {
                 runService
                     .createOrUpdate(
                         runNumber,