File size: 500 Bytes
c27e67a | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 | defmodule Plausible.Workers.LockSites do
use Plausible.Repo
use Oban.Worker, queue: :lock_sites
alias Plausible.Teams
@impl Oban.Worker
def perform(_job) do
teams =
Repo.all(
from t in Teams.Team,
as: :team,
left_lateral_join: s in subquery(Teams.last_subscription_join_query()),
on: true,
preload: [subscription: s]
)
for team <- teams do
Plausible.Billing.SiteLocker.update_for(team)
end
:ok
end
end
|