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