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:, data_ds:, log_table:, task_id:, force: false, logger:) ⇒ NoopJob

Returns a new instance of NoopJob.



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

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

Instance Method Details

#execute(fail_fast: false) ⇒ Object 



163
164
165
166
167
 
# File 'lib/bricolage/streamingload/taskhandler.rb', line 163

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

#execute_task ⇒ Object 



169
170
171
 
# File 'lib/bricolage/streamingload/taskhandler.rb', line 169

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