lib/ddr/managers/derivatives_manager.rb in ddr-models-3.0.0.alpha.2 vs lib/ddr/managers/derivatives_manager.rb in ddr-models-3.0.0.alpha.3

- old
+ new

@@ -17,11 +17,11 @@ derivative = Ddr::Derivatives::DERIVATIVES[derivative_to_update] # Need to update derivative if either (or both) of the following conditions are true: # - object already has this derivative (need to delete or replace it) # - the derivative can be generated for this object if derivative.class.has_derivative?(object) || derivative.class.generatable?(object) - schedule == SCHEDULE_NOW ? update_derivative(derivative) : Resque.enqueue(DerivativeJob, object.pid, derivative_to_update) + schedule == SCHEDULE_NOW ? update_derivative(derivative) : Resque.enqueue(DerivativeJob, object.id, derivative_to_update) end end end def update_derivative(derivative) @@ -36,19 +36,19 @@ end end def generate_derivative(derivative) ActiveSupport::Notifications.instrument(Ddr::Notifications::UPDATE, - pid: object.pid, + pid: object.id, summary: "Generate #{derivative.class.name} derivative" ) do |payload| derivative.generate!(object) end end def delete_derivative(derivative) ActiveSupport::Notifications.instrument(Ddr::Notifications::UPDATE, - pid: object.pid, + pid: object.id, summary: "Delete derivative #{derivative.class.name}" ) do |payload| derivative.delete!(object) end end