Module: Airflow

Defined in:
lib/async_flow.rb,
lib/async_flow/task.rb,
lib/async_flow/state.rb,
lib/async_flow/utils.rb,
lib/async_flow/client.rb,
lib/async_flow/future.rb,
lib/async_flow/logger.rb,
lib/async_flow/models.rb,
lib/async_flow/runner.rb,
lib/async_flow/worker.rb,
lib/async_flow/reactor.rb,
lib/async_flow/version.rb,
lib/async_flow/commands.rb,
lib/async_flow/handlers.rb,
lib/async_flow/workflow.rb,
lib/async_flow/executors.rb,
lib/async_flow/definition.rb,
lib/async_flow/persistence.rb,
lib/async_flow/sig_handler.rb

Defined Under Namespace

Modules: Commands, Definition, Executors, Handlers, Models, Persistence, Runner, Task, Utils, Workflow Classes: Client, Error, Future, Logger, Reactor, SigHandler, State, Worker

Constant Summary collapse

VERSION = 
"0.1.1"

Class Method Summary collapse

Class Method Details

.logger ⇒ Object 



17
18
19
20
21
 
# File 'lib/async_flow.rb', line 17

def self.logger
  @logger ||= Logger.new($stdout, level: :debug, progname: "async-flow").tap do |log|
    log.formatter = Airflow::Logger::Formatters::Base.new
  end
end

.logger=(logger) ⇒ Object 



23
24
25
 
# File 'lib/async_flow.rb', line 23

def self.logger=(logger)
  @logger = logger
end

.mediator ⇒ Object 



27
28
29
 
# File 'lib/async_flow.rb', line 27

def self.mediator
  @mediator ||= Mediator.init
end