Module: Karafka::Pro::RecurringTasks::Errors

Defined in:

lib/karafka/pro/recurring_tasks/errors.rb

Overview

Recurring Tasks related errors

Constant Summary

BaseError =

Base for all the recurring tasks errors

Class.new(::Karafka::Errors::BaseError)

IncompatibleSchemaError =

Raised when older cron manager version is trying to work with newer schema

Class.new(BaseError)

IncompatibleScheduleError =

Raised if you use versioned schedule and an existing schedule from Kafka was picked up by a process with older schedule version. This is a safe-guard to protect against a cases where there would be a temporary reassignment of newer schedule data into older process during deployment. It should go away once all processes are rolled.

Class.new(BaseError)