Module: Airflow::Persistence

Defined in:
lib/async_flow/persistence.rb

Defined Under Namespace

Classes: InMemoryRepository, WorkflowRunRepository

Constant Summary collapse

EntityNotFound = 
Class.new(StandardError)

Class Method Summary collapse

Class Method Details

.clear ⇒ Object

TODO: Define persistence interfaces.



10
11
12
 
# File 'lib/async_flow/persistence.rb', line 10

def self.clear
  workflow_runs.clear
end

.workflow_runs ⇒ Object 



14
15
16
 
# File 'lib/async_flow/persistence.rb', line 14

def self.workflow_runs
  @workflow_runs ||= WorkflowRunRepository.new
end