app/models/agents/human_task_agent.rb

@@ -169,7 +169,7 @@ module Agents

                     def review_hits
              

                       reviewable_hit_ids = RTurk::GetReviewableHITs.create.hit_ids
              

                       my_reviewed_hit_ids = reviewable_hit_ids & (memory[:hits] || {}).keys.map(&:to_s)
              

                -      log "MTurk reports the following HITs [#{reviewable_hit_ids.to_sentence}], of which I own [#{my_reviewed_hit_ids.to_sentence}]"
              

                +      log "MTurk reports #{reviewable_hit_ids.length} HITs, of which I own [#{my_reviewed_hit_ids.to_sentence}]"
              

                       my_reviewed_hit_ids.each do |hit_id|
              

                         hit = RTurk::Hit.new(hit_id)
              

                         assignments = hit.assignments
              
@@ -215,6 +215,7 @@ module Agents

                           log "Event emitted with answer(s)", :outbound_event => event, :inbound_event => Event.find_by_id(memory[:hits][hit_id.to_sym])
              

                 
              

                           assignments.each(&:approve!)
              

                +          hit.dispose!
              

                 
              

                           memory[:hits].delete(hit_id.to_sym)
              

                         end
              

spec/models/agents/human_task_agent_spec.rb

@@ -220,6 +220,14 @@ describe Agents::HumanTaskAgent do

                       def max_assignments
              

                         @options[:max_assignments] || 1
              

                       end
              

                +
              

                +      def dispose!
              

                +        @disposed = true
              

                +      end
              

                +
              

                +      def disposed?
              

                +        @disposed
              

                +      end
              

                     end
              

                 
              

                     class FakeAssignment
              
@@ -309,6 +317,7 @@ describe Agents::HumanTaskAgent do

                         FakeAssignment.new(:status => "Submitted", :answers => {"sentiment"=>"happy", "feedback"=>"Take 2"})
              

                       ]
              

                       hit = FakeHit.new(:max_assignments => 2, :assignments => assignments)
              

                +      hit.should_not be_disposed
              

                       mock(RTurk::Hit).new("JH3132836336DHG") { hit }
              

                 
              

                       lambda {
              
@@ -316,6 +325,7 @@ describe Agents::HumanTaskAgent do

                       }.should change { Event.count }.by(1)
              

                 
              

                       assignments.all? {|a| a.approved == true }.should be_true
              

                +      hit.should be_disposed
              

                 
              

                       @checker.events.last.payload[:answers].should == [
              

                         {:sentiment => "neutral", :feedback => ""},