lib/sidekiq/hierarchy/faraday/middleware.rb in sidekiq-hierarchy-0.1.2 vs lib/sidekiq/hierarchy/faraday/middleware.rb in sidekiq-hierarchy-0.1.3
- old
+ new
@@ -4,11 +4,13 @@
module Sidekiq
module Hierarchy
module Faraday
class Middleware < ::Faraday::Middleware
def call(env)
- env[:request_headers][Sidekiq::Hierarchy::Http::JID_HEADER] = Sidekiq::Hierarchy.current_jid if Sidekiq::Hierarchy.current_jid
- env[:request_headers][Sidekiq::Hierarchy::Http::WORKFLOW_HEADER] = Sidekiq::Hierarchy.current_workflow.jid if Sidekiq::Hierarchy.current_workflow
+ if Sidekiq::Hierarchy.current_workflow && Sidekiq::Hierarchy.current_jid
+ env[:request_headers][Sidekiq::Hierarchy::Http::JID_HEADER] = Sidekiq::Hierarchy.current_jid
+ env[:request_headers][Sidekiq::Hierarchy::Http::WORKFLOW_HEADER] = Sidekiq::Hierarchy.current_workflow.jid
+ end
@app.call(env)
end
end
end
end