gistfile1.txt

== worker intercepted error ==

#<ArgumentError: wrong number of arguments (2 for 1)>
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/activesupport-3.0.7/lib/active_support/core_ext/object/to_json.rb:19:in `to_json'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/json_pure-1.5.1/lib/json/common.rb:212:in `generate'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/json_pure-1.5.1/lib/json/common.rb:212:in `generate'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/rufus-json-0.2.7/lib/rufus/json.rb:37:in `block in <module:Json>'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/rufus-json-0.2.7/lib/rufus/json.rb:124:in `call'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/rufus-json-0.2.7/lib/rufus/json.rb:124:in `encode'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/rufus-json-0.2.7/lib/rufus/json.rb:171:in `dup'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/rufus-cloche-0.1.21/lib/rufus/cloche.rb:82:in `put'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/storage/fs_storage.rb:68:in `put'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/storage/base.rb:70:in `put_msg'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/receiver/base.rb:44:in `receive'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/receiver/base.rb:97:in `reply_to_engine'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/part/block_participant.rb:80:in `consume'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/svc/dispatch_pool.rb:74:in `do_dispatch'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/svc/dispatch_pool.rb:101:in `block in do_threaded_dispatch'
...

-- msg --
              _id : "56869!2200327120!2011-05-23!1306139092.887658!095"
             _rev : 0
           action : "dispatch"
              fei : "0_1_2!600735a86b2eeebe007261805d130733!20110523-bobutsudipe"
      participant : ["Ruote::BlockParticipant", {"on_workitem"=>"proc do |workitem|\n        dataset_urls = []\n        workitem.fields['studies_to_download'] ||= []\n\n        queries = ArchiveStudyQuery.all\n\n        for query in queries\n          query.save!\n          query_response_file = \"\#{$xml_dir}query_response_\#{Time.now.to_i}.xml\"\n\n          `curl -o \#{query_response_file} --compressed \"\#{query.query}\"`\n          handler = Nesstar::QueryResponseParser.new(query_response_file)\n\n          for url in handler.datasets\n            ddi_id = url.split(\".\").last\n            #the validations on the object ensure we don't duplicate the object (archive + query must be unique, url can repeat)\n            pre_existing = ArchiveStudyIntegration.find_by_archive_id_and_ddi_id(query.archive.id, ddi_id)\n            unless pre_existing\n              ArchiveStudyIntegration.create!(:ddi_id => ddi_id, :archive => query.archive,\n                                            :archive_study_query => query, :user_id => query.id)\n            end\n          end\n        end\n        \n        catalogs = ArchiveCatalogIntegration.all\n        \n        for catalog in catalogs\n          archive = catalog.archive\n          file = \"\#{$catalogs_xml_dir}\#{archive.slug}/\#{catalog.label}@datasets.xml\" #request all datasets referenced by this catalog\n\n          `curl -o \#{file} --compressed \"\#{catalog.url}@datasets\"`\n          studies_in_catalog = Nesstar::RDF::Parser.parse_catalog_children(\"\#{file}\")\n          \n          for study in studies_in_catalog\n            ddi_id = study[:resource].split(\".\").last\n            ArchiveStudyIntegration.create!(:ddi_id => ddi_id, :archive => catalog.archive, :archive_catalog_integration_id => catalog.id)\n          end\n        end\n        \n        workitem.fields['studies_to_download'] = Set.new\n        ArchiveStudyIntegration.all.each do |integration|\n          workitem.fields['studies_to_download'] <<  integration.ddi_id\n        end\n      end"}]
 participant_name : "load_study_integrations"
           put_at : "2011-05-23 08:24:52.887688 UTC"
             type : "msgs"
         workitem : {"fields"=>{"__result__"=>nil, "children_to_parents"=>{}, "archive_catalog_integrations"=>[1, 3, 5, 2, 4], "params"=>{"ref"=>"load_study_integrations"}, "dispatched_at"=>"2011-05-23 08:24:52.892862 UTC", "studies_to_download"=>#<Set: {"00822-p02", "00102-f", "00967", "00102-h", "00986", "00102-m", "01159", "00115", "00103", "00349", "00601", "00602", "00822-c02", "00822-p01", "00603", "00822-c01", "00604"}>}, "wf_name"=>"convert_datasets", "wf_revision"=>nil, "fei"=>{"engine_id"=>"engine", "wfid"=>"20110523-bobutsudipe", "subid"=>"600735a86b2eeebe007261805d130733", "expid"=>"0_1_2"}, "participant_name"=>"load_study_integrations"}
-- . --

rake aborted!
wrong number of arguments (2 for 1)
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/activesupport-3.0.7/lib/active_support/core_ext/object/to_json.rb:19:in `to_json'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/json_pure-1.5.1/lib/json/common.rb:212:in `generate'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/json_pure-1.5.1/lib/json/common.rb:212:in `generate'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/rufus-json-0.2.7/lib/rufus/json.rb:37:in `block in <module:Json>'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/rufus-json-0.2.7/lib/rufus/json.rb:124:in `call'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/rufus-json-0.2.7/lib/rufus/json.rb:124:in `encode'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/rufus-json-0.2.7/lib/rufus/json.rb:171:in `dup'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/gems/rufus-cloche-0.1.21/lib/rufus/cloche.rb:82:in `put'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/storage/fs_storage.rb:68:in `put'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/storage/base.rb:70:in `put_msg'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/svc/error_handler.rb:111:in `handle'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/svc/error_handler.rb:51:in `msg_handle'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/svc/dispatch_pool.rb:104:in `rescue in block in do_threaded_dispatch'
/Users/nicholas/.rvm/gems/ruby-1.9.2-p0/bundler/gems/ruote-0a22f137c90b/lib/ruote/svc/dispatch_pool.rb:99:in `block in do_threaded_dispatch'