Class: Bricolage::StreamingLoad::NoopJob

Inherits:
Object
  • Object
show all
Defined in:
lib/bricolage/streamingload/taskhandler.rb

Instance Method Summary collapse

Constructor Details

#initialize(context:, ctl_ds:, task_id:, force: false, logger:) ⇒ NoopJob

Returns a new instance of NoopJob.



152
153
154
155
156
157
158
 
# File 'lib/bricolage/streamingload/taskhandler.rb', line 152

def initialize(context:, ctl_ds:, task_id:, force: false, logger:)
  @ctx = context
  @ctl_ds = ctl_ds
  @task_id = task_id
  @force = force
  @logger = logger
end

Instance Method Details

#execute(fail_fast: false) ⇒ Object 



160
161
162
163
164
 
# File 'lib/bricolage/streamingload/taskhandler.rb', line 160

def execute(fail_fast: false)
  @logger.info "execute: fail_fast=#{fail_fast}"
  execute_task
  true
end

#execute_task ⇒ Object 



166
167
168
 
# File 'lib/bricolage/streamingload/taskhandler.rb', line 166

def execute_task
  @logger.info "execute_task: task_id=#{@task_id} force=#{@force} ctx=#{@ctx.home_path} ctl_ds=#{@ctl_ds.name} dir=#{@working_dir}"
end