Module: Taskr
- Includes:
- Models
- Defined in:
- lib/taskr/version.rb,
lib/taskr.rb,
lib/taskr.rb,
lib/taskr/actions.rb
Overview
Defined Under Namespace
Modules: Actions, Controllers, Helpers, Models, VERSION, Views
Constant Summary
collapse
- @@scheduler =
nil
Class Method Summary
collapse
Class Method Details
.create ⇒ Object
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
# File 'lib/taskr.rb', line 46
def Taskr.create
$LOG.info "Initializing Taskr..."
Taskr::Models::Base.establish_connection(Taskr::Conf.database)
Taskr::Models.create_schema
if self::Conf[:external_actions]
if self::Conf[:external_actions].kind_of? Array
external_actions = self::Conf[:external_actions]
else
external_actions = [self::Conf[:external_actions]]
end
external_actions.each do |f|
$LOG.info "Loading additional action definitions from #{self::Conf[:external_actions]}..."
require f
end
end
end
|
.prestart ⇒ Object
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
# File 'lib/taskr.rb', line 64
def Taskr.prestart
$LOG.info "Starting OpenWFE Scheduler..."
Taskr.scheduler = OpenWFE::Scheduler.new
Taskr.scheduler.start
$LOG.debug "Scheduler is: #{Taskr.scheduler.inspect}"
tasks = Taskr::Models::Task.find(:all)
$LOG.info "Scheduling #{tasks.length} persisted tasks..."
tasks.each do |t|
t.schedule! Taskr.scheduler
end
Taskr.scheduler.instance_variable_get(:@scheduler_thread).run
end
|
.scheduler ⇒ Object
29
30
31
|
# File 'lib/taskr.rb', line 29
def self.scheduler
@@scheduler
end
|
.scheduler=(scheduler) ⇒ Object
26
27
28
|
# File 'lib/taskr.rb', line 26
def self.scheduler=(scheduler)
@@scheduler = scheduler
end
|