diff --git a/app/jobs/fees/create_pay_in_advance_job.rb b/app/jobs/fees/create_pay_in_advance_job.rb index 3424c2380a7..6c7fba33ba1 100644 --- a/app/jobs/fees/create_pay_in_advance_job.rb +++ b/app/jobs/fees/create_pay_in_advance_job.rb @@ -4,8 +4,6 @@ module Fees class CreatePayInAdvanceJob < ApplicationJob queue_as :default - unique :until_executed, on_conflict: :log - def perform(charge:, event:, billing_at: nil) result = Fees::CreatePayInAdvanceService.call(charge:, event:, billing_at:) diff --git a/app/jobs/integrations/aggregator/credit_notes/create_job.rb b/app/jobs/integrations/aggregator/credit_notes/create_job.rb index f575bec8c08..eb0bd189660 100644 --- a/app/jobs/integrations/aggregator/credit_notes/create_job.rb +++ b/app/jobs/integrations/aggregator/credit_notes/create_job.rb @@ -6,8 +6,6 @@ module CreditNotes class CreateJob < ApplicationJob queue_as 'integrations' - unique :until_executed, on_conflict: :log - retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 3 retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100 diff --git a/app/jobs/integrations/aggregator/invoices/create_job.rb b/app/jobs/integrations/aggregator/invoices/create_job.rb index 6d2c00604d0..75218dd026a 100644 --- a/app/jobs/integrations/aggregator/invoices/create_job.rb +++ b/app/jobs/integrations/aggregator/invoices/create_job.rb @@ -6,8 +6,6 @@ module Invoices class CreateJob < ApplicationJob queue_as 'integrations' - unique :until_executed, on_conflict: :log - retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 3 retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100 diff --git a/app/jobs/integrations/aggregator/invoices/crm/create_customer_association_job.rb b/app/jobs/integrations/aggregator/invoices/crm/create_customer_association_job.rb index 938748eec1d..dbf980328b5 100644 --- a/app/jobs/integrations/aggregator/invoices/crm/create_customer_association_job.rb +++ b/app/jobs/integrations/aggregator/invoices/crm/create_customer_association_job.rb @@ -7,8 +7,6 @@ module Crm class CreateCustomerAssociationJob < ApplicationJob queue_as 'integrations' - unique :until_executed, on_conflict: :log - retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 10 retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100 diff --git a/app/jobs/integrations/aggregator/invoices/crm/create_job.rb b/app/jobs/integrations/aggregator/invoices/crm/create_job.rb index 85770a419a4..44155e8a363 100644 --- a/app/jobs/integrations/aggregator/invoices/crm/create_job.rb +++ b/app/jobs/integrations/aggregator/invoices/crm/create_job.rb @@ -7,8 +7,6 @@ module Crm class CreateJob < ApplicationJob queue_as 'integrations' - unique :until_executed, on_conflict: :log - retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 10 retry_on Integrations::Aggregator::BasePayload::Failure, wait: :polynomially_longer, attempts: 10 retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100 diff --git a/app/jobs/integrations/aggregator/invoices/crm/update_job.rb b/app/jobs/integrations/aggregator/invoices/crm/update_job.rb index 288a1494a56..45418dd6eea 100644 --- a/app/jobs/integrations/aggregator/invoices/crm/update_job.rb +++ b/app/jobs/integrations/aggregator/invoices/crm/update_job.rb @@ -7,8 +7,6 @@ module Crm class UpdateJob < ApplicationJob queue_as 'integrations' - unique :until_executed, on_conflict: :log - retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 10 retry_on Integrations::Aggregator::BasePayload::Failure, wait: :polynomially_longer, attempts: 10 retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100 diff --git a/app/jobs/integrations/aggregator/payments/create_job.rb b/app/jobs/integrations/aggregator/payments/create_job.rb index 7bb27404fa1..dafba9a2c11 100644 --- a/app/jobs/integrations/aggregator/payments/create_job.rb +++ b/app/jobs/integrations/aggregator/payments/create_job.rb @@ -6,8 +6,6 @@ module Payments class CreateJob < ApplicationJob queue_as 'integrations' - unique :until_executed, on_conflict: :log - retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 5 retry_on Integrations::Aggregator::BasePayload::Failure, wait: :polynomially_longer, attempts: 10 retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100 diff --git a/app/jobs/integrations/aggregator/subscriptions/crm/create_customer_association_job.rb b/app/jobs/integrations/aggregator/subscriptions/crm/create_customer_association_job.rb index 93ec015ceff..cfc36a76771 100644 --- a/app/jobs/integrations/aggregator/subscriptions/crm/create_customer_association_job.rb +++ b/app/jobs/integrations/aggregator/subscriptions/crm/create_customer_association_job.rb @@ -7,8 +7,6 @@ module Crm class CreateCustomerAssociationJob < ApplicationJob queue_as 'integrations' - unique :until_executed, on_conflict: :log - retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 10 retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100 diff --git a/app/jobs/integrations/aggregator/subscriptions/crm/create_job.rb b/app/jobs/integrations/aggregator/subscriptions/crm/create_job.rb index dec20f5e496..0a2cf9ce63e 100644 --- a/app/jobs/integrations/aggregator/subscriptions/crm/create_job.rb +++ b/app/jobs/integrations/aggregator/subscriptions/crm/create_job.rb @@ -7,8 +7,6 @@ module Crm class CreateJob < ApplicationJob queue_as 'integrations' - unique :until_executed, on_conflict: :log - retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 10 retry_on Integrations::Aggregator::BasePayload::Failure, wait: :polynomially_longer, attempts: 10 retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100 diff --git a/app/jobs/integrations/aggregator/subscriptions/crm/update_job.rb b/app/jobs/integrations/aggregator/subscriptions/crm/update_job.rb index 347e3361c31..8860fd0d9e8 100644 --- a/app/jobs/integrations/aggregator/subscriptions/crm/update_job.rb +++ b/app/jobs/integrations/aggregator/subscriptions/crm/update_job.rb @@ -7,8 +7,6 @@ module Crm class UpdateJob < ApplicationJob queue_as 'integrations' - unique :until_executed, on_conflict: :log - retry_on LagoHttpClient::HttpError, wait: :polynomially_longer, attempts: 10 retry_on Integrations::Aggregator::BasePayload::Failure, wait: :polynomially_longer, attempts: 10 retry_on RequestLimitError, wait: :polynomially_longer, attempts: 100 diff --git a/app/jobs/invoices/create_pay_in_advance_charge_job.rb b/app/jobs/invoices/create_pay_in_advance_charge_job.rb index 0b8af74a670..83971caf51b 100644 --- a/app/jobs/invoices/create_pay_in_advance_charge_job.rb +++ b/app/jobs/invoices/create_pay_in_advance_charge_job.rb @@ -6,8 +6,6 @@ class CreatePayInAdvanceChargeJob < ApplicationJob retry_on Sequenced::SequenceError - unique :until_executed, on_conflict: :log - def perform(charge:, event:, timestamp:, invoice: nil) result = Invoices::CreatePayInAdvanceChargeService.call(charge:, event:, timestamp:, invoice:) return if result.success?