Commit fac901ae authored by Daniel Seybold's avatar Daniel Seybold

added task logs to YCSB perforamnce and scalability

parent a373530f
Pipeline #85925 passed with stage
in 13 minutes and 58 seconds
...@@ -19,9 +19,11 @@ import de.uulm.omi.evaluation.task.DeployDB; ...@@ -19,9 +19,11 @@ import de.uulm.omi.evaluation.task.DeployDB;
import de.uulm.omi.evaluation.task.FetchYcsbResult; import de.uulm.omi.evaluation.task.FetchYcsbResult;
import de.uulm.omi.evaluation.task.InitEvaluation; import de.uulm.omi.evaluation.task.InitEvaluation;
import de.uulm.omi.evaluation.task.InitRun; import de.uulm.omi.evaluation.task.InitRun;
import de.uulm.omi.evaluation.task.LogTask;
import de.uulm.omi.evaluation.task.Plotting; import de.uulm.omi.evaluation.task.Plotting;
import de.uulm.omi.evaluation.task.Plotting.PlottingTask; import de.uulm.omi.evaluation.task.Plotting.PlottingTask;
import de.uulm.omi.evaluation.task.RemoteCommand; import de.uulm.omi.evaluation.task.TaskState;
import de.uulm.omi.evaluation.task.TaskType;
import de.uulm.omi.evaluation.task.YcsbWorkload; import de.uulm.omi.evaluation.task.YcsbWorkload;
import de.uulm.omi.utils.YcsbWorkloadType; import de.uulm.omi.utils.YcsbWorkloadType;
import org.jeasy.flows.engine.WorkFlowEngine; import org.jeasy.flows.engine.WorkFlowEngine;
...@@ -100,15 +102,21 @@ public class PerformanceYCSBWriteScenario extends EvaluationScenario { ...@@ -100,15 +102,21 @@ public class PerformanceYCSBWriteScenario extends EvaluationScenario {
runFlow = aNewSequentialFlow() runFlow = aNewSequentialFlow()
.execute(initRun) .execute(initRun)
.execute(deployDB) .execute(deployDB)
.execute(new LogTask(evaluationContext, TaskType.DEPLOY_DB, TaskState.STARTED))
.execute(checkDeployment) .execute(checkDeployment)
.execute(new LogTask(evaluationContext, TaskType.DEPLOY_DB, TaskState.FINISHED))
.execute(ycsbWorkload) .execute(ycsbWorkload)
.execute(new LogTask(evaluationContext, TaskType.YCSB_LOAD, TaskState.STARTED))
.execute(checkWorkload) .execute(checkWorkload)
.execute(new LogTask(evaluationContext, TaskType.YCSB_LOAD, TaskState.FINISHED))
.execute(fetchYcsbResult) .execute(fetchYcsbResult)
.execute(mergeYCSB) .execute(mergeYCSB)
.execute(evaluationTimeseries) .execute(evaluationTimeseries)
.execute(workloadTimeseries) .execute(workloadTimeseries)
.execute(systemTimeseries) .execute(systemTimeseries)
.execute(new LogTask(evaluationContext, TaskType.CLEANUP, TaskState.STARTED))
.execute(cleanUpResources) .execute(cleanUpResources)
.execute(new LogTask(evaluationContext, TaskType.CLEANUP, TaskState.FINISHED))
.execute(cleanUpRun) .execute(cleanUpRun)
.build(); .build();
......
...@@ -17,9 +17,12 @@ import de.uulm.omi.evaluation.task.DeployDB; ...@@ -17,9 +17,12 @@ import de.uulm.omi.evaluation.task.DeployDB;
import de.uulm.omi.evaluation.task.FetchYcsbResult; import de.uulm.omi.evaluation.task.FetchYcsbResult;
import de.uulm.omi.evaluation.task.InitEvaluation; import de.uulm.omi.evaluation.task.InitEvaluation;
import de.uulm.omi.evaluation.task.InitRun; import de.uulm.omi.evaluation.task.InitRun;
import de.uulm.omi.evaluation.task.LogTask;
import de.uulm.omi.evaluation.task.Plotting; import de.uulm.omi.evaluation.task.Plotting;
import de.uulm.omi.evaluation.task.Plotting.PlottingTask; import de.uulm.omi.evaluation.task.Plotting.PlottingTask;
import de.uulm.omi.evaluation.task.RemoteCommand; import de.uulm.omi.evaluation.task.RemoteCommand;
import de.uulm.omi.evaluation.task.TaskState;
import de.uulm.omi.evaluation.task.TaskType;
import de.uulm.omi.evaluation.task.YcsbWorkload; import de.uulm.omi.evaluation.task.YcsbWorkload;
import de.uulm.omi.utils.YcsbWorkloadType; import de.uulm.omi.utils.YcsbWorkloadType;
import org.jeasy.flows.engine.WorkFlowEngine; import org.jeasy.flows.engine.WorkFlowEngine;
...@@ -103,19 +106,25 @@ public class ScalabilityYCSBWriteScenario extends EvaluationScenario { ...@@ -103,19 +106,25 @@ public class ScalabilityYCSBWriteScenario extends EvaluationScenario {
failureAwareFlow = aNewSequentialFlow() failureAwareFlow = aNewSequentialFlow()
.execute(initRun) .execute(initRun)
.execute(deployDB) .execute(deployDB)
.execute(new LogTask(evaluationContext, TaskType.DEPLOY_DB, TaskState.STARTED))
.then(aNewConditionalFlow() .then(aNewConditionalFlow()
.execute(checkDeployment) .execute(checkDeployment)
.when(WorkReportPredicate.COMPLETED) .when(WorkReportPredicate.COMPLETED)
.then(aNewSequentialFlow() .then(aNewSequentialFlow()
.execute(new LogTask(evaluationContext, TaskType.DEPLOY_DB, TaskState.FINISHED))
.execute(ycsbWorkload) .execute(ycsbWorkload)
.execute(new LogTask(evaluationContext, TaskType.YCSB_LOAD, TaskState.STARTED))
.execute(checkWorkload) .execute(checkWorkload)
.execute(new LogTask(evaluationContext, TaskType.YCSB_LOAD, TaskState.FINISHED))
.execute(fetchYcsbResult) .execute(fetchYcsbResult)
.execute(remoteCommand) .execute(remoteCommand)
.execute(mergeYCSB) .execute(mergeYCSB)
.execute(evaluationTimeseries) .execute(evaluationTimeseries)
.execute(workloadTimeseries) .execute(workloadTimeseries)
.execute(systemTimeseries) .execute(systemTimeseries)
.execute(new LogTask(evaluationContext, TaskType.CLEANUP, TaskState.STARTED))
.execute(cleanUpResources) .execute(cleanUpResources)
.execute(new LogTask(evaluationContext, TaskType.CLEANUP, TaskState.FINISHED))
.execute(cleanUpRun) .execute(cleanUpRun)
.build()) .build())
.otherwise( .otherwise(
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment