Class: SpreeCmCommissioner::Integrations::PollingSchedulerJob

Inherits:

BaseJob

• Object
• ActiveJob::Base
• ApplicationJob
• ApplicationJob
• BaseJob
• SpreeCmCommissioner::Integrations::PollingSchedulerJob

Defined in:

app/jobs/spree_cm_commissioner/integrations/polling_scheduler_job.rb

Overview

Scheduler job that runs periodically to enqueue integration polling jobs

This job is responsible for:

• Running full syncs every 24 hours

• Running incremental syncs every 10 seconds

• Webhook syncs are triggered externally (not scheduled here)

The job queries all active integrations and enqueues appropriate pull jobs based on their last sync time and sync type configuration.

Instance Method Summary

• #perform ⇒ Object

Methods included from ApplicationJobDecorator

handle_deserialization_error, prepended

Instance Method Details

#perform ⇒ Object

# File 'app/jobs/spree_cm_commissioner/integrations/polling_scheduler_job.rb', line 13

def perform
  SpreeCmCommissioner::Integrations::PollingScheduler.new.call
rescue StandardError => e
  handle_scheduler_error(e)
  raise
end