summaryrefslogtreecommitdiff
path: root/lazar.rb
diff options
context:
space:
mode:
authorMartin Gütlein <martin.guetlein@gmail.com>2010-04-19 13:46:53 +0200
committerMartin Gütlein <martin.guetlein@gmail.com>2010-04-19 13:46:53 +0200
commitb35562025820e9f687e0cd798d572975eb11732b (patch)
tree76ebc7812721bac45b72c9a570bf53b050691fe0 /lazar.rb
parente94b77ecba273c7d9fc3563ea1195ee489a7a704 (diff)
use as_task() for building lazar
Diffstat (limited to 'lazar.rb')
-rw-r--r--lazar.rb22
1 files changed, 5 insertions, 17 deletions
diff --git a/lazar.rb b/lazar.rb
index df57152..1c0ba73 100644
--- a/lazar.rb
+++ b/lazar.rb
@@ -38,12 +38,8 @@ post '/lazar/?' do # create a model
halt 404, "No feature #{params[:prediction_feature]} in dataset #{params[:dataset_uri]}. (features: "+
training_activities.features.inspect+")" unless training_activities.features and training_activities.features.include?(params[:prediction_feature])
- task = OpenTox::Task.create
-
- pid = Spork.spork(:logger => LOGGER) do
-
- task.started
- LOGGER.debug "Lazar task #{task.uri} started #{Time.now}"
+ response['Content-Type'] = 'text/uri-list'
+ OpenTox::Task.as_task do |task|
# create features
LOGGER.debug "Starting fminer"
@@ -52,11 +48,8 @@ post '/lazar/?' do # create a model
fminer_task = OpenTox::Task.find(fminer_task_uri)
fminer_task.parent = task
fminer_task.wait_for_completion
- if fminer_task.failed?
- LOGGER.error "Fminer failed"
- task.failed
- break
- end
+ raise "fminer failed" if fminer_task.failed?
+
LOGGER.debug "Fminer finished #{Time.now}"
feature_dataset_uri = fminer_task.resource.to_s
training_features = OpenTox::Dataset.find(feature_dataset_uri)
@@ -108,12 +101,7 @@ post '/lazar/?' do # create a model
model_uri = lazar.save
LOGGER.info model_uri + " created #{Time.now}"
- task.completed(model_uri)
+ model_uri
end
- LOGGER.debug "Lazar task PID: " + pid.to_s
- task.pid = pid
- #status 303
- response['Content-Type'] = 'text/uri-list'
- task.uri + "\n"
end