Skip to content

Commit 4cd9c9a

Browse files
committed
feat: Add uid and gid columns to users and kernels tables
1 parent 42b4030 commit 4cd9c9a

File tree

3 files changed

+48
-0
lines changed

3 files changed

+48
-0
lines changed
Lines changed: 43 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,43 @@
1+
"""add uid and gid columns
2+
3+
Revision ID: f6ca2f2d04c1
4+
Revises: 0bb88d5a46bf
5+
Create Date: 2024-12-20 12:16:07.077845
6+
7+
"""
8+
9+
import sqlalchemy as sa
10+
from alembic import op
11+
12+
# revision identifiers, used by Alembic.
13+
revision = "f6ca2f2d04c1"
14+
down_revision = "0bb88d5a46bf"
15+
branch_labels = None
16+
depends_on = None
17+
18+
19+
def upgrade() -> None:
20+
op.add_column(
21+
"kernels", sa.Column("uid", sa.Integer(), server_default=sa.text("NULL"), nullable=True)
22+
)
23+
op.add_column(
24+
"kernels",
25+
sa.Column("gids", sa.ARRAY(sa.Integer()), server_default=sa.text("NULL"), nullable=True),
26+
)
27+
op.add_column(
28+
"users",
29+
sa.Column("container_uid", sa.Integer(), server_default=sa.text("NULL"), nullable=True),
30+
)
31+
op.add_column(
32+
"users",
33+
sa.Column(
34+
"container_gids", sa.ARRAY(sa.Integer()), server_default=sa.text("NULL"), nullable=True
35+
),
36+
)
37+
38+
39+
def downgrade() -> None:
40+
op.drop_column("users", "container_gids")
41+
op.drop_column("users", "container_uid")
42+
op.drop_column("kernels", "gids")
43+
op.drop_column("kernels", "uid")

src/ai/backend/manager/models/kernel.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -416,6 +416,9 @@ class KernelRow(Base):
416416
cluster_hostname = sa.Column(
417417
"cluster_hostname", sa.String(length=64), nullable=False, default=default_hostname
418418
)
419+
uid = sa.Column("uid", sa.Integer, nullable=True, server_default=sa.null())
420+
gids = sa.Column("gids", sa.ARRAY(sa.Integer), nullable=True, server_default=sa.null())
421+
419422
# Resource ownership
420423
scaling_group = sa.Column(
421424
"scaling_group", sa.ForeignKey("scaling_groups.name"), index=True, nullable=True

src/ai/backend/manager/models/user.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -159,6 +159,8 @@ class UserStatus(enum.StrEnum):
159159
sa.ForeignKey("keypairs.access_key", ondelete="SET NULL"),
160160
nullable=True, # keypairs.user is non-nullable
161161
),
162+
sa.Column("container_uid", sa.Integer, nullable=True, server_default=sa.null()),
163+
sa.Column("container_gids", sa.ARRAY(sa.Integer), nullable=True, server_default=sa.null()),
162164
)
163165

164166

0 commit comments

Comments
 (0)