Class: Airflow::Runner::TaskRunner

Inherits:

BaseRunner

• Object
• BaseRunner
• Airflow::Runner::TaskRunner

Defined in:

lib/async_flow/runner.rb

Overview

TODO: Remove reference to worker, not used

Instance Method Summary

• #initialize ⇒ TaskRunner constructor

  A new instance of TaskRunner.

Methods inherited from BaseRunner

#run, #stop

Methods included from Utils::Logger

#logger

Constructor Details

#initialize ⇒ TaskRunner

Returns a new instance of TaskRunner.

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

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