Method: Airflow::Runner::TaskRunner#initialize

Defined in:
lib/async_flow/runner.rb

#initialize ⇒ TaskRunner

Returns a new instance of TaskRunner.



85
86
87
88
 
# File 'lib/async_flow/runner.rb', line 85

def initialize(...)
  super
  poller.is_workflow_task = false
end