lib/pallets.rb in pallets-0.2.0 vs lib/pallets.rb in pallets-0.3.0
- old
+ new
@@ -1,13 +1,15 @@
require "pallets/version"
require 'pallets/backends/base'
require 'pallets/backends/redis'
require 'pallets/configuration'
+require 'pallets/context'
require 'pallets/dsl/workflow'
require 'pallets/errors'
require 'pallets/graph'
+require 'pallets/logger'
require 'pallets/manager'
require 'pallets/pool'
require 'pallets/scheduler'
require 'pallets/serializers/base'
require 'pallets/serializers/json'
@@ -15,11 +17,10 @@
require 'pallets/task'
require 'pallets/util'
require 'pallets/worker'
require 'pallets/workflow'
-require 'logger'
require 'securerandom'
module Pallets
def self.configuration
@configuration ||= Configuration.new
@@ -33,10 +34,11 @@
@backend ||= begin
cls = Pallets::Util.constantize("Pallets::Backends::#{configuration.backend.capitalize}")
cls.new(
namespace: configuration.namespace,
blocking_timeout: configuration.blocking_timeout,
+ failed_job_lifespan: configuration.failed_job_lifespan,
job_timeout: configuration.job_timeout,
pool_size: configuration.pool_size,
**configuration.backend_args
)
end
@@ -48,8 +50,19 @@
cls.new
end
end
def self.logger
- @logger ||= Logger.new(STDOUT)
+ @logger ||= begin
+ logger = Pallets::Logger.new(STDOUT)
+ # TODO: Ruby 2.4 supports Logger initialization with the arguments below, so
+ # we can drop this after we drop support for Ruby 2.3
+ logger.level = Pallets::Logger::INFO
+ logger.formatter = Pallets::Logger::Formatters::Pretty.new
+ logger
+ end
+ end
+
+ def self.logger=(logger)
+ @logger = logger
end
end