Moved validation before running workload in several threads

Author: Emgariko

ydb/library/workload/abstract/workload_query_generator.h

@@ -178,6 +178,7 @@ class TWorkloadParams {
     }
     virtual TString GetWorkloadName() const = 0;
 
+    virtual void Validate() const {};
 public:
     ui64 BulkSize = 10000;
     std::string DbPath;

ydb/library/workload/log/log.cpp

@@ -445,7 +445,7 @@ void TLogWorkloadParams::Validate() const {
     if (dateFromPassed && dateToPassed && *TimestampDateFrom >= *TimestampDateTo) {
         throw yexception() << "Invalid interval [`date-from`, `date-to`)";
     }
-
+    
     return;
 }
 
@@ -505,8 +505,6 @@ void TLogWorkloadParams::ConfigureOpts(NLastGetopt::TOpts& opts, const ECommandT
 }
 
 THolder<IWorkloadQueryGenerator> TLogWorkloadParams::CreateGenerator() const {
-    Validate();
-
     return MakeHolder<TLogGenerator>(this);
 }
 

ydb/library/workload/log/log.h

@@ -37,8 +37,8 @@ class TLogWorkloadParams : public TWorkloadParams {
     YDB_READONLY(EStoreType, StoreType, EStoreType::Row);
     TWorkloadDataInitializer::TList CreateDataInitializers() const override;
 
+    void Validate() const override;
 private:
-    void Validate() const;
     void ConfigureOptsFillData(NLastGetopt::TOpts& opts);
     void ConfigureOptsColumns(NLastGetopt::TOpts& opts);
 };

ydb/public/lib/ydb_cli/commands/ydb_workload.cpp

@@ -279,9 +279,7 @@ int TWorkloadCommand::RunWorkload(NYdbWorkload::IWorkloadQueryGenerator& workloa
     StopTime = StartTime + TDuration::Seconds(TotalSec);
 
     NPar::LocalExecutor().RunAdditionalThreads(Threads);
-    // bool invalidParams = false;
-    // До разделения на потоки сделать валидацию.
-    
+
     auto futures = NPar::LocalExecutor().ExecRangeWithFutures([this, &workloadGen, type](int id) {
         try {
             WorkerFn(id, workloadGen, type);
@@ -353,6 +351,7 @@ int TWorkloadCommandRun::Run(TConfig& config) {
     PrepareForRun(config);
     Params.DbPath = config.Database;
     auto workloadGen = Params.CreateGenerator();
+    Params.Validate();
     return RunWorkload(*workloadGen, Type);
 }