✨ Add ordering to function jobs inside a function job collection

packages/postgres-database/src/simcore_postgres_database/migration/versions/06596ce2bc3e_add_order_to_function_job_collections.py

@@ -0,0 +1,75 @@
+"""add order to function job collections
+
+Revision ID: 06596ce2bc3e
+Revises: 9dddb16914a4
+Create Date: 2025-10-08 13:54:39.943703+00:00
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "06596ce2bc3e"
+down_revision = "9dddb16914a4"
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column(
+        "funcapi_function_job_collections_to_function_jobs",
+        sa.Column("order", sa.Integer(), default=0, nullable=True),
+    )
+    # Set the "order" column so that it restarts from 1 for each collection_id,
+    # ordering by function_job_id within each collection
+    op.execute(
+        sa.text(
+            """
+            UPDATE funcapi_function_job_collections_to_function_jobs
+            SET "order" = sub.row_number
+            FROM (
+                SELECT function_job_collection_uuid, function_job_uuid,
+                       ROW_NUMBER() OVER (PARTITION BY function_job_collection_uuid) AS row_number
+                FROM funcapi_function_job_collections_to_function_jobs
+            ) AS sub
+            WHERE funcapi_function_job_collections_to_function_jobs.function_job_collection_uuid = sub.function_job_collection_uuid
+              AND funcapi_function_job_collections_to_function_jobs.function_job_uuid = sub.function_job_uuid
+            """
+        )
+    )
+    op.drop_constraint(
+        "funcapi_function_job_collections_to_function_jobs_pk",
+        "funcapi_function_job_collections_to_function_jobs",
+        type_="primary",
+    )
+    op.create_primary_key(
+        "funcapi_function_job_collections_to_function_jobs_pk",
+        "funcapi_function_job_collections_to_function_jobs",
+        ["function_job_collection_uuid", "order"],
+    )
+    op.alter_column(
+        "funcapi_function_job_collections_to_function_jobs",
+        "order",
+        existing_type=sa.Integer(),
+        nullable=False,
+    )
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_constraint(
+        "funcapi_function_job_collections_to_function_jobs_pk",
+        "funcapi_function_job_collections_to_function_jobs",
+        type_="primary",
+    )
+    op.create_primary_key(
+        "funcapi_function_job_collections_to_function_jobs_pk",
+        "funcapi_function_job_collections_to_function_jobs",
+        ["function_job_collection_uuid", "function_job_uuid"],
+    )
+
+    op.drop_column("funcapi_function_job_collections_to_function_jobs", "order")
+    # ### end Alembic commands ###

packages/postgres-database/src/simcore_postgres_database/models/funcapi_function_job_collections_to_function_jobs_table.py

@@ -35,11 +35,18 @@
         nullable=False,
         doc="Unique identifier of the function job",
     ),
+    sa.Column(
+        "order",
+        sa.Integer,
+        nullable=False,
+        doc="Order of the function job in the collection",
+    ),
     column_created_datetime(),
     column_modified_datetime(),
     sa.PrimaryKeyConstraint(
         "function_job_collection_uuid",
         "function_job_uuid",
+        "order",
         name="funcapi_function_job_collections_to_function_jobs_pk",
     ),
 )

services/web/server/src/simcore_service_webserver/functions/_function_job_collections_repository.py

@@ -95,12 +95,13 @@ async def create_function_job_collection(
             row
         )
         job_collection_entries: list[Row] = []
-        for job_id in job_ids:
+        for order, job_id in enumerate(job_ids, 1):
             result = await transaction.execute(
                 function_job_collections_to_function_jobs_table.insert()
                 .values(
                     function_job_collection_uuid=function_job_collection_db.uuid,
                     function_job_uuid=job_id,
+                    order=order,
                 )
                 .returning(
                     function_job_collections_to_function_jobs_table.c.function_job_collection_uuid,
@@ -228,10 +229,12 @@ async def list_function_job_collections(
             job_ids = [
                 job_row.function_job_uuid
                 async for job_row in await conn.stream(
-                    function_job_collections_to_function_jobs_table.select().where(
+                    function_job_collections_to_function_jobs_table.select()
+                    .where(
                         function_job_collections_to_function_jobs_table.c.function_job_collection_uuid
                         == row.uuid
                     )
+                    .order_by(function_job_collections_to_function_jobs_table.c.order)
                 )
             ]
             collections.append((collection, job_ids))
@@ -278,10 +281,12 @@ async def get_function_job_collection(
         job_ids = [
             job_row.function_job_uuid
             async for job_row in await conn.stream(
-                function_job_collections_to_function_jobs_table.select().where(
+                function_job_collections_to_function_jobs_table.select()
+                .where(
                     function_job_collections_to_function_jobs_table.c.function_job_collection_uuid
                     == row.uuid
                 )
+                .order_by(function_job_collections_to_function_jobs_table.c.order)
             )
         ]
 

services/web/server/src/simcore_service_webserver/functions/_function_jobs_repository.py

@@ -209,6 +209,7 @@ async def list_function_jobs_with_status(
                     function_job_collections_to_function_jobs_table.c.function_job_collection_uuid
                     == filter_by_function_job_collection_id
                 )
+                .order_by(function_job_collections_to_function_jobs_table.c.order)
             )
             filter_conditions = sqlalchemy.and_(
                 filter_conditions,