[autofix.ci] apply automated fixes

Author: autofix-ci[bot]

api/controllers/console/app/workflow_alias.py

@@ -19,7 +19,6 @@
 
 
 class WorkflowAliasApi(Resource):
-
     @setup_required
     @login_required
     @account_initialization_required
@@ -123,6 +122,3 @@ def delete(self, app_model: App):
             return {"message": "Alias deleted successfully"}
         except ValueError as e:
             raise BadRequest(str(e))
-
-
-

api/controllers/service_api/app/completion.py

@@ -174,7 +174,7 @@ def _resolve_workflow_alias(self, app_model: App, args: dict) -> None:
                 session=db.session,
                 tenant_id=app_model.tenant_id,
                 app_id=app_model.id,
-                alias_name=args["workflow_alias"]
+                alias_name=args["workflow_alias"],
             )
 
             if not workflow:

api/controllers/service_api/app/workflow.py

@@ -182,10 +182,7 @@ def _resolve_workflow_id(self, app_model: App, identifier: str) -> str:
         """
         workflow_alias_service = WorkflowAliasService()
         workflow = workflow_alias_service.get_workflow_by_alias(
-            session=db.session,
-            tenant_id=app_model.tenant_id,
-            app_id=app_model.id,
-            alias_name=identifier
+            session=db.session, tenant_id=app_model.tenant_id, app_id=app_model.id, alias_name=identifier
         )
 
         if workflow:
@@ -198,8 +195,7 @@ def _resolve_workflow_id(self, app_model: App, identifier: str) -> str:
         except (ValueError, TypeError):
             # Neither alias nor valid UUID format
             raise WorkflowIdFormatError(
-                f"Invalid identifier '{identifier}'. "
-                f"Must be a valid workflow alias or UUID format."
+                f"Invalid identifier '{identifier}'. Must be a valid workflow alias or UUID format."
             )
 
 

api/models/workflow_alias.py

@@ -12,8 +12,9 @@
 
 class AliasType(Enum):
     """Alias type enumeration"""
-    SYSTEM = "system"    # System aliases like 'production', 'staging'
-    CUSTOM = "custom"    # User-defined custom aliases
+
+    SYSTEM = "system"  # System aliases like 'production', 'staging'
+    CUSTOM = "custom"  # User-defined custom aliases
 
 
 class WorkflowAlias(Base):
@@ -38,7 +39,7 @@ class WorkflowAlias(Base):
 
     __tablename__ = "workflow_aliases"
     __allow_unmapped__ = True  # Allow non-mapped attributes
-    __slots__ = ('_is_transferred', '_old_workflow_id')
+    __slots__ = ("_is_transferred", "_old_workflow_id")
     __table_args__ = (
         sa.PrimaryKeyConstraint("id", name="workflow_alias_pkey"),
         # Ensure alias name is unique within an app
@@ -54,23 +55,12 @@ class WorkflowAlias(Base):
     app_id: Mapped[str] = mapped_column(StringUUID, nullable=False)
     workflow_id: Mapped[str] = mapped_column(StringUUID, nullable=False)
     alias_name: Mapped[str] = mapped_column(String(255), nullable=False)
-    alias_type: Mapped[str] = mapped_column(
-        String(50),
-        nullable=False,
-        server_default=AliasType.CUSTOM.value
-    )
+    alias_type: Mapped[str] = mapped_column(String(50), nullable=False, server_default=AliasType.CUSTOM.value)
 
     created_by: Mapped[str] = mapped_column(StringUUID, nullable=False)
-    created_at: Mapped[datetime] = mapped_column(
-        sa.DateTime,
-        nullable=False,
-        server_default=func.current_timestamp()
-    )
+    created_at: Mapped[datetime] = mapped_column(sa.DateTime, nullable=False, server_default=func.current_timestamp())
     updated_at: Mapped[datetime] = mapped_column(
-        sa.DateTime,
-        nullable=False,
-        server_default=func.current_timestamp(),
-        onupdate=func.current_timestamp()
+        sa.DateTime, nullable=False, server_default=func.current_timestamp(), onupdate=func.current_timestamp()
     )
 
     def __init__(self, *args, **kwargs):
@@ -82,6 +72,7 @@ def __init__(self, *args, **kwargs):
     def created_by_account(self):
         """Get the account that created this alias"""
         from .engine import db
+
         return db.session.get(Account, self.created_by)
 
     @property

api/services/workflow_alias_service.py

@@ -15,7 +15,6 @@
 
 
 class WorkflowAliasService:
-
     def create_alias(
         self,
         session: Union[Session, "scoped_session"],
@@ -34,12 +33,7 @@ def create_alias(
             raise ValueError("Cannot create or transfer aliases for draft workflows")
 
         existing_alias = session.execute(
-            select(WorkflowAlias).where(
-                and_(
-                    WorkflowAlias.app_id == app_id,
-                    WorkflowAlias.alias_name == alias_name
-                )
-            )
+            select(WorkflowAlias).where(and_(WorkflowAlias.app_id == app_id, WorkflowAlias.alias_name == alias_name))
         ).scalar_one_or_none()
 
         if existing_alias:
@@ -51,8 +45,7 @@ def create_alias(
             existing_alias._old_workflow_id = old_workflow_id
 
             logger.info(
-                "Transferred alias '%s' from workflow %s to workflow %s",
-                alias_name, old_workflow_id, workflow_id
+                "Transferred alias '%s' from workflow %s to workflow %s", alias_name, old_workflow_id, workflow_id
             )
             return existing_alias
 
@@ -69,10 +62,7 @@ def create_alias(
         session.add(alias)
         session.flush()
 
-        logger.info(
-            "Created workflow alias: %s for workflow %s",
-            alias_name, workflow_id
-        )
+        logger.info("Created workflow alias: %s for workflow %s", alias_name, workflow_id)
         return alias
 
     def get_aliases_by_app(
@@ -82,17 +72,12 @@ def get_aliases_by_app(
         app_id: str,
         workflow_ids: Optional[list[str]] = None,
     ) -> list[WorkflowAlias]:
-        conditions = [
-            WorkflowAlias.tenant_id == tenant_id,
-            WorkflowAlias.app_id == app_id
-        ]
+        conditions = [WorkflowAlias.tenant_id == tenant_id, WorkflowAlias.app_id == app_id]
 
         if workflow_ids:
             conditions.append(WorkflowAlias.workflow_id.in_(workflow_ids))
 
-        stmt = select(WorkflowAlias).where(
-            and_(*conditions)
-        ).order_by(WorkflowAlias.created_at.desc())
+        stmt = select(WorkflowAlias).where(and_(*conditions)).order_by(WorkflowAlias.created_at.desc())
 
         return list(session.execute(stmt).scalars().all())
 
@@ -108,7 +93,7 @@ def get_workflow_by_alias(
                 and_(
                     WorkflowAlias.tenant_id == tenant_id,
                     WorkflowAlias.app_id == app_id,
-                    WorkflowAlias.alias_name == alias_name
+                    WorkflowAlias.alias_name == alias_name,
                 )
             )
         ).scalar_one_or_none()