Class: Tasker::Orchestration::TaskFinalizer::FinalizationDecisionMaker

Inherits:
Object
  • Object
show all
Defined in:
lib/tasker/orchestration/task_finalizer.rb

Overview

Service class to make finalization decisions Reduces complexity by organizing decision-making logic

Class Method Summary collapse

Class Method Details

.make_finalization_decision(task, context, synchronous, finalizer) ⇒ Object

Make finalization decision based on task state

Parameters:



252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
 
# File 'lib/tasker/orchestration/task_finalizer.rb', line 252

def make_finalization_decision(task, context, synchronous, finalizer)
  Rails.logger.info("TaskFinalizer: Making decision for task #{task.task_id} with execution_status: #{context&.execution_status}")

  # DEBUG: Log detailed context information
  if context
    Rails.logger.info("TaskFinalizer: Task #{task.task_id} context details - ready_steps: #{context.ready_steps}, total_steps: #{context.total_steps}, pending_steps: #{context.pending_steps}, in_progress_steps: #{context.in_progress_steps}, completed_steps: #{context.completed_steps}, failed_steps: #{context.failed_steps}")
  end

  # Handle nil context case
  unless context
    Rails.logger.info("TaskFinalizer: Task #{task.task_id} - no context available, handling as unclear state")
    UnclearStateHandler.handle(task, context, finalizer)
    return
  end

  case context.execution_status
  when Constants::TaskExecution::ExecutionStatus::ALL_COMPLETE
    Rails.logger.info("TaskFinalizer: Task #{task.task_id} - calling complete_task")
    finalizer.complete_task(task, context)
  when Constants::TaskExecution::ExecutionStatus::BLOCKED_BY_FAILURES
    Rails.logger.info("TaskFinalizer: Task #{task.task_id} - calling error_task")
    finalizer.error_task(task, context)
  when Constants::TaskExecution::ExecutionStatus::HAS_READY_STEPS
    Rails.logger.info("TaskFinalizer: Task #{task.task_id} - has ready steps, should execute them")
    handle_ready_steps_state(task, context, synchronous, finalizer)
  when Constants::TaskExecution::ExecutionStatus::WAITING_FOR_DEPENDENCIES
    Rails.logger.info("TaskFinalizer: Task #{task.task_id} - waiting for dependencies")
    handle_waiting_state(task, context, synchronous, finalizer)
  when Constants::TaskExecution::ExecutionStatus::PROCESSING
    Rails.logger.info("TaskFinalizer: Task #{task.task_id} - handling processing state")
    handle_processing_state(task, context, synchronous, finalizer)
  else
    Rails.logger.info("TaskFinalizer: Task #{task.task_id} - handling unclear state")
    UnclearStateHandler.handle(task, context, finalizer)
  end
end