Skip to content

Commit de7d9d6

Browse files
committed
WPB-28377: run arbiter job migrations in brig migrate-postgres
1 parent e16a71a commit de7d9d6

2 files changed

Lines changed: 8 additions & 1 deletion

File tree

libs/wire-subsystems/src/Wire/JobSubsystem/Migrations.hs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,13 @@
1919
-- with this program. If not, see <https://www.gnu.org/licenses/>.
2020

2121
module Wire.JobSubsystem.Migrations
22-
( mkArbiterConnectionString,
22+
( defaultSchemaName,
23+
mkArbiterConnectionString,
2324
runJobMigrations,
2425
)
2526
where
2627

28+
import Arbiter.Core (defaultSchemaName)
2729
import Arbiter.Migrations qualified as ArbiterMigrations
2830
import Control.Exception (bracket, bracket_, throwIO)
2931
import Data.Hashable qualified as Hashable

services/brig/src/Brig/Run.hs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,7 @@ import Wire.API.Routes.Version
6969
import Wire.API.Routes.Version.Wai
7070
import Wire.API.User (AccountStatus (PendingInvitation))
7171
import Wire.DeleteQueue
72+
import Wire.JobSubsystem.Migrations (defaultSchemaName, mkArbiterConnectionString, runJobMigrations)
7273
import Wire.OpenTelemetry (withTracer)
7374
import Wire.PostgresMigrations
7475
import Wire.Sem.Paging qualified as P
@@ -117,6 +118,10 @@ migratePostgres opts resetFirst = do
117118
pool <- (.rawPool) <$> initPostgresPool opts.postgresqlPool opts.postgresql opts.postgresqlPassword
118119
when resetFirst $ resetSchema pool logger
119120
runAllMigrations pool logger
121+
-- Also create the arbiter job schema, so that this command yields the full
122+
-- database schema (e.g. for `make postgres-schema`).
123+
arbiterConnStr <- mkArbiterConnectionString opts.postgresql opts.postgresqlPassword
124+
runJobMigrations arbiterConnStr defaultSchemaName
120125
flush logger
121126

122127
mkApp :: Opts -> IO (Wai.Application, Env)

0 commit comments

Comments
 (0)