class Bricolage::StreamingLoad::NoopJob

Public Class Methods

new(context:, ctl_ds:, data_ds:, log_table:, task_id:, force: false, logger:) click to toggle source
# File lib/bricolage/streamingload/taskhandler.rb, line 155
def initialize(context:, ctl_ds:, data_ds:, log_table:, task_id:, force: false, logger:)
  @ctx = context
  @ctl_ds = ctl_ds
  @data_ds = data_ds
  @log_table = log_table
  @task_id = task_id
  @force = force
  @logger = logger
  @working_dir = Dir.getwd
end

Public Instance Methods

execute(fail_fast: false) click to toggle source
# File lib/bricolage/streamingload/taskhandler.rb, line 166
def execute(fail_fast: false)
  @logger.info "execute: fail_fast=#{fail_fast}"
  execute_task
  true
end
execute_task() click to toggle source
# File lib/bricolage/streamingload/taskhandler.rb, line 172
def execute_task
  @logger.info "execute_task: task_id=#{@task_id} force=#{@force} ctx=#{@ctx.home_path} ctl_ds=#{@ctl_ds.name} data_ds=#{@data_ds.name} dir=#{@working_dir}"
end