Class: CeleryClient::TaskManager

Inherits:
Object
  • Object
show all
Defined in:
lib/celery_client/task_manager.rb

Instance Method Summary collapse

Constructor Details

#initialize(connection, wait = true, timeout = 60, verbose = false) ⇒ TaskManager

Returns a new instance of TaskManager.



7
8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/celery_client/task_manager.rb', line 7

def initialize(connection, wait=true, timeout=60, verbose=false)
  @connection = connection
  @timeout = Integer(timeout)
  @tasks = {}
  @wait = wait
  if @wait.is_a?(String)
    @wait = to_boolean(@wait)
  end
  @verbose = verbose
  if @verbose.is_a?(String)
    @verbose = to_boolean(@verbose)
  end
end

Instance Method Details

#result(task_id) ⇒ Object 



37
38
39
40
 
# File 'lib/celery_client/task_manager.rb', line 37

def result(task_id)
  check_task(task_id)
  check_for_result(task_id)
end

#run(context, task_name, params) ⇒ Object 



21
22
23
24
25
26
27
28
29
30
 
# File 'lib/celery_client/task_manager.rb', line 21

def run(context, task_name, params)
  if @verbose
    puts "Executing #{context}/#{task_name} with payload #{params}" 
  end
  result = @connection.post(
    get_run_path(context, task_name), params)
  task_id = get_task_id(result)
  save_task(task_id, context, task_name, params)
  task_id
end

#status(task_id) ⇒ Object 



32
33
34
35
 
# File 'lib/celery_client/task_manager.rb', line 32

def status(task_id)
  check_task(task_id)
  check_for_status(task_id)
end