SqlExecutor

update_pipeline()
- Pipeline

AutonomousExecutor

AutonomousExecutor

UpdatePipeline
- PipelineDerivatives

1. replace PipelineDerivatives

GenericWorker

PerformanceMonitor
Worker

1. reset PerformanceMetrics
2. send UpdatePerformanceMetrics

TaskExecutor

cleanup()
update_pipeline()

PerformanceMonitor
Worker

GenericWorker

1. replace
   PerformanceMetrics

GenericWorker

IncrementalUpdateMetrics
- MetricsUpdateByTaskExecution

PerformanceMonitor
Worker

1. update PerformanceMetrics

PerformanceMonitor
Worker

ReportMetricsSummary
- PerformanceMetricsSummary

MemoryStateMachine
Worker

1. transit state (if triggered)
   

WebConsoleReporter

report_metrics()
- PerformanceMetrics

MemoryStateMachine
Worker

TransitMemoryState
- MemoryStateTransition

• [* -> Moderate] set FlowEfficientScheduler
• [* -> Severe] set MemoryReducingScheduler
• [* -> Critical] pause

GenericWorker

SourceWorker

• [* -> Moderate] set SourceScheduler
• [* -> Severe] set SourceScheduler
• [* -> Critical] pause

PurgerWorker

• [* -> Moderate] pause
• [* -> Severe] pause
• [* -> Critical] purge

SourceWorker

1. replace PipelineDerivatives

SourceWorker

IncrementalUpdateMetrics
- MetricsUpdateByTaskExecution

PerformanceMonitor
Worker

1. update PerformanceMetrics

UpdatePerformanceMetrics
- PerformanceMetrics