Drop deleted_by_user cols

Author: r4victor

src/dstack/_internal/server/background/pipeline_tasks/gateways.py

@@ -25,7 +25,6 @@
     GatewayComputeModel,
     GatewayModel,
     ProjectModel,
-    UserModel,
 )
 from dstack._internal.server.services import backends as backends_services
 from dstack._internal.server.services import events
@@ -431,9 +430,6 @@ async def _process_to_be_deleted_item(item: GatewayPipelineItem):
             )
             .options(joinedload(GatewayModel.project).joinedload(ProjectModel.backends))
             .options(joinedload(GatewayModel.gateway_compute))
-            .options(
-                joinedload(GatewayModel.deleted_by_user).load_only(UserModel.id, UserModel.name)
-            )
         )
         gateway_model = res.unique().scalar_one_or_none()
         if gateway_model is None:
@@ -465,13 +461,10 @@ async def _process_to_be_deleted_item(item: GatewayPipelineItem):
                     item.id,
                 )
                 return
-            actor = events.SystemActor()
-            if gateway_model.deleted_by_user is not None:
-                actor = events.UserActor.from_user(gateway_model.deleted_by_user)
             events.emit(
                 session,
                 "Gateway deleted",
-                actor=actor,
+                actor=events.SystemActor(),
                 targets=[events.Target.from_model(gateway_model)],
             )
         else:

src/dstack/_internal/server/migrations/versions/2026/02_20_0840_d911914ecf17_add_gatewaymodel_deleted_columns.py

@@ -0,0 +1,34 @@
+"""Add GatewayModel.to_be_deleted
+
+Revision ID: 3160b6c59d94
+Revises: 66c2fdda33c2
+Create Date: 2026-02-20 09:14:31.650140+00:00
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "3160b6c59d94"
+down_revision = "66c2fdda33c2"
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    # ### commands auto generated by Alembic - please adjust! ###
+    with op.batch_alter_table("gateways", schema=None) as batch_op:
+        batch_op.add_column(
+            sa.Column("to_be_deleted", sa.Boolean(), server_default=sa.text("0"), nullable=False)
+        )
+
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    # ### commands auto generated by Alembic - please adjust! ###
+    with op.batch_alter_table("gateways", schema=None) as batch_op:
+        batch_op.drop_column("to_be_deleted")
+
+    # ### end Alembic commands ###

src/dstack/_internal/server/migrations/versions/2026/02_20_0914_3160b6c59d94_add_gatewaymodel_to_be_deleted.py

@@ -522,10 +522,6 @@ class GatewayModel(PipelineModelMixin, BaseModel):
     runs: Mapped[List["RunModel"]] = relationship(back_populates="gateway")
 
     to_be_deleted: Mapped[bool] = mapped_column(Boolean, server_default=false())
-    deleted_by_user_id: Mapped[Optional[uuid.UUID]] = mapped_column(
-        ForeignKey("users.id", ondelete="SET NULL")
-    )
-    deleted_by_user: Mapped[Optional[UserModel]] = relationship(foreign_keys=[deleted_by_user_id])
 
     __table_args__ = (UniqueConstraint("project_id", "name", name="uq_gateways_project_id_name"),)
 

src/dstack/_internal/server/models.py

@@ -310,7 +310,12 @@ async def delete_gateways(
         for gateway_model in gateway_models:
             if not gateway_model.to_be_deleted:
                 gateway_model.to_be_deleted = True
-                gateway_model.deleted_by_user_id = user.id
+                events.emit(
+                    session,
+                    "Gateway marked for deletion",
+                    actor=events.UserActor.from_user(user),
+                    targets=[events.Target.from_model(gateway_model)],
+                )
         await session.commit()
 
 

src/dstack/_internal/server/services/gateways/__init__.py

@@ -20,7 +20,6 @@
     create_gateway,
     create_gateway_compute,
     create_project,
-    create_user,
     list_events,
 )
 
@@ -194,7 +193,6 @@ class TestGatewayWorkerDeleted:
     async def test_deletes_gateway_and_marks_compute_deleted(
         self, test_db, session: AsyncSession, worker: GatewayWorker
     ):
-        user = await create_user(session=session)
         project = await create_project(session=session)
         backend = await create_backend(session=session, project_id=project.id)
         gateway_compute = await create_gateway_compute(session=session, backend_id=backend.id)
@@ -208,7 +206,6 @@ async def test_deletes_gateway_and_marks_compute_deleted(
         gateway.lock_token = uuid.uuid4()
         gateway.lock_expires_at = datetime(2025, 1, 2, 3, 4, tzinfo=timezone.utc)
         gateway.to_be_deleted = True
-        gateway.deleted_by_user_id = user.id
         await session.commit()
 
         with (
@@ -237,7 +234,6 @@ async def test_deletes_gateway_and_marks_compute_deleted(
         events = await list_events(session)
         assert len(events) == 1
         assert events[0].message == "Gateway deleted"
-        assert events[0].actor_user_id == user.id
 
     async def test_keeps_gateway_if_terminate_fails(
         self, test_db, session: AsyncSession, worker: GatewayWorker