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