# Avvia/riavvia il relay YouTube sul worker del nodo (coda youtube_relay_<slug>).
class YoutubeRelayEnsureJob < ApplicationJob
  queue_as Streams::YoutubeRelay::QUEUE

  def perform(session_id)
    session = StreamSession.find_by(id: session_id)
    return unless session

    Streams::YoutubeRelay.ensure_on_worker!(session)
  end
end