Class: Airflow::Task::Base

Inherits:
Object
  • Object
show all
Defined in:
lib/async_flow/task.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

._type ⇒ Object 



13
14
15
 
# File 'lib/async_flow/task.rb', line 13

def self._type
  @_type || name
end

.inherited(subclass) ⇒ Object 



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

def self.inherited(subclass)
  Airflow::Task.definitions << subclass
  super
end

.task_name(name) ⇒ Object 



9
10
11
 
# File 'lib/async_flow/task.rb', line 9

def self.task_name(name)
  @_type = name
end

Instance Method Details

#execute ⇒ Object

Raises:

  • (NotImplementedError) 


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

def execute
  raise NotImplementedError, "Abstract method"
end