Adding a passthrough option to the statistic action

src/multio/action/statistics/Statistics.cc

@@ -33,6 +33,7 @@ using message::glossary;
 Statistics::Statistics(const ComponentConfiguration& compConf) :
     ChainedAction{compConf},
     needRestart_{false},
+    initialDataAlreadyPassedThrough_{false},
     lastDateTime_{""},
     opt_{compConf},
     operations_{compConf.parsedConfig().getStringVector("operations")},
@@ -332,6 +333,16 @@ void Statistics::executeImpl(message::Message msg) {
         stat = fieldStats_.find(key);
     }
 
+    // If the action sets the option that initial data is supposed to be passed to the next action in case of several statistic actions, 
+    // AND the model sends initial data AND the internal tracker if any message has been directly passed through is still false the message is passed through to the next action
+    // TODO check if this is a good position for this check. It looks like the next chekc would filter this message out anyway. 
+    //std::cout<<"STEBA opt_.solver_send_initial_condition() " << opt_.solver_send_initial_condition() << " opt_.initialDataPassThrough() " << opt_.initialDataPassThrough() <<" !initialDataAlreadyPassedThrough_ " << !initialDataAlreadyPassedThrough_ << std::endl;
+    if(opt_.solver_send_initial_condition() &&  opt_.initialDataPassThrough() && !initialDataAlreadyPassedThrough_) {
+        initialDataAlreadyPassedThrough_ = true;
+        executeNext(msg);
+        return;
+    }
+
     // Exit if the current time is the same as the current point in the
     // window and the solver does not send the initial condition.
     // This can happen when the solver is sending the initial condition

src/multio/action/statistics/Statistics.h

@@ -40,6 +40,7 @@ class Statistics : public ChainedAction {
 private:
     bool needRestart_;
     std::string lastDateTime_;
+    bool initialDataAlreadyPassedThrough_;
     void TryDumpRestart(const message::Message& msg);
     std::string generateRestartNameFromFlush(const message::Message& msg) const;
     void DeleteLatestSymLink();

src/multio/action/statistics/cfg/StatisticsOptions.cc

@@ -35,6 +35,7 @@ StatisticsOptions::StatisticsOptions(const config::ComponentConfiguration& compC
         parseStepFrequency(options);
         parseTimeStep(options);
         parseInitialConditionPresent(options);
+        parseInitialDataPassThrough(options);
         parseWriteRestart(options);
         parseDebugRestart(options);
         parseClientSideStatistics(options);
@@ -84,6 +85,14 @@ void StatisticsOptions::parseInitialConditionPresent(const eckit::LocalConfigura
     return;
 };
 
+void StatisticsOptions::parseInitialDataPassThrough(const eckit::LocalConfiguration& cfg) {
+    //This option needs to be set if we have two statistic actions in a plan. Then the second statistic action also needs the initial data to create the statistic window correctly. 
+    //Therefore the first action needs to have this option set to true. 
+    initDataPassTrough_ = cfg.getBool("initial-data-passed-through", false); 
+    return;
+}
+
+
 void StatisticsOptions::parseWriteRestart(const eckit::LocalConfiguration& cfg) {
     // Used to determine if the simulation need to save/load
     // restart files.
@@ -306,6 +315,10 @@ const std::string& StatisticsOptions::solverResetAccumulatedFields() const {
     return accumulatedFieldsResetFreqency_;
 };
 
+bool StatisticsOptions::initialDataPassThrough() const {
+    return initDataPassTrough_;
+};
+
 
 std::optional<long> StatisticsOptions::valueCountThreshold() const {
     return valueCountThreshold_;

src/multio/action/statistics/cfg/StatisticsOptions.h

@@ -19,6 +19,7 @@ class StatisticsOptions {
     long stepFreq_;
     long timeStep_;
     bool solverSendInitStep_;
+    bool initDataPassTrough_;
     bool readRestart_;
     bool writeRestart_;
     bool debugRestart_;
@@ -41,6 +42,7 @@ class StatisticsOptions {
     void parseStepFrequency(const eckit::LocalConfiguration& cfg);
     void parseTimeStep(const eckit::LocalConfiguration& cfg);
     void parseInitialConditionPresent(const eckit::LocalConfiguration& cfg);
+    void parseInitialDataPassThrough(const eckit::LocalConfiguration& cfg);
     void parseWriteRestart(const eckit::LocalConfiguration& cfg);
     void parseDebugRestart(const eckit::LocalConfiguration& cfg);
     void parseClientSideStatistics(const eckit::LocalConfiguration& cfg);
@@ -77,6 +79,7 @@ class StatisticsOptions {
     bool writeRestart() const;
     bool debugRestart() const;
     bool clientSideStatistics() const;
+    bool initialDataPassThrough() const;
 
     const std::string& restartTime() const;
     const std::string& restartPath() const;