diff options
author | Martin Gütlein <martin.guetlein@gmail.com> | 2010-04-19 13:46:53 +0200 |
---|---|---|
committer | Martin Gütlein <martin.guetlein@gmail.com> | 2010-04-19 13:46:53 +0200 |
commit | b35562025820e9f687e0cd798d572975eb11732b (patch) | |
tree | 76ebc7812721bac45b72c9a570bf53b050691fe0 /lazar.rb | |
parent | e94b77ecba273c7d9fc3563ea1195ee489a7a704 (diff) |
use as_task() for building lazar
Diffstat (limited to 'lazar.rb')
-rw-r--r-- | lazar.rb | 22 |
1 files changed, 5 insertions, 17 deletions
@@ -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 |