update script

Author: giancarloromeo

packages/postgres-database/src/simcore_postgres_database/migration/versions/5c69e5661f45_move_projects_workbench.py renamed to packages/postgres-database/src/simcore_postgres_database/migration/versions/50af59b6c37a_move_projects_workbench.py

@@ -1,42 +1,39 @@
 """Move projects workbench
 
-Revision ID: 5c69e5661f45
+Revision ID: 50af59b6c37a
 Revises: 307017ee1a49
-Create Date: 2025-01-13 13:45:47.583609+00:00
+Create Date: 2025-01-15 12:39:46.219516+00:00
 
 """
 from alembic import op
 import sqlalchemy as sa
 from sqlalchemy.dialects import postgresql
 
 # revision identifiers, used by Alembic.
-revision = '5c69e5661f45'
+revision = '50af59b6c37a'
 down_revision = '307017ee1a49'
 branch_labels = None
 depends_on = None
 
 
 def upgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.add_column('projects_nodes', sa.Column('key', sa.String(), nullable=False))
-    op.add_column('projects_nodes', sa.Column('version', sa.String(), nullable=False))
-    op.add_column('projects_nodes', sa.Column('label', sa.String(), nullable=False))
-    op.add_column('projects_nodes', sa.Column('progress', sa.Numeric(), nullable=True))
-    op.add_column('projects_nodes', sa.Column('thumbnail', sa.String(), nullable=True))
-    op.add_column('projects_nodes', sa.Column('input_access', postgresql.JSONB(astext_type=sa.Text()), nullable=True))
-    op.add_column('projects_nodes', sa.Column('input_nodes', postgresql.JSONB(astext_type=sa.Text()), nullable=True))
-    op.add_column('projects_nodes', sa.Column('inputs', postgresql.JSONB(astext_type=sa.Text()), nullable=True))
-    op.add_column('projects_nodes', sa.Column('inputs_required', postgresql.JSONB(astext_type=sa.Text()), nullable=True))
-    op.add_column('projects_nodes', sa.Column('inputs_units', postgresql.JSONB(astext_type=sa.Text()), nullable=True))
-    op.add_column('projects_nodes', sa.Column('output_nodes', postgresql.JSONB(astext_type=sa.Text()), nullable=True))
-    op.add_column('projects_nodes', sa.Column('outputs', postgresql.JSONB(astext_type=sa.Text()), nullable=True))
-    op.add_column('projects_nodes', sa.Column('run_hash', sa.String(), nullable=True))
-    op.add_column('projects_nodes', sa.Column('state', postgresql.JSONB(astext_type=sa.Text()), nullable=True))
-    op.add_column('projects_nodes', sa.Column('parent', sa.String(), nullable=True))
-    op.add_column('projects_nodes', sa.Column('boot_options', postgresql.JSONB(astext_type=sa.Text()), nullable=True))
-    # ### end Alembic commands ###
+    op.add_column('projects_nodes', sa.Column('key', sa.String(), nullable=False, comment='Distinctive name (based on the Docker registry path)'))
+    op.add_column('projects_nodes', sa.Column('version', sa.String(), nullable=False, comment='Semantic version number'))
+    op.add_column('projects_nodes', sa.Column('label', sa.String(), nullable=False, comment='Short name '))
+    op.add_column('projects_nodes', sa.Column('progress', sa.Numeric(), nullable=True, comment='Progress value'))
+    op.add_column('projects_nodes', sa.Column('thumbnail', sa.String(), nullable=True, comment='Url of the latest screenshot'))
+    op.add_column('projects_nodes', sa.Column('input_access', postgresql.JSONB(astext_type=sa.Text()), nullable=True, comment='Map with key - access level pairs'))
+    op.add_column('projects_nodes', sa.Column('input_nodes', postgresql.JSONB(astext_type=sa.Text()), nullable=True, comment='IDs of the nodes where is connected to'))
+    op.add_column('projects_nodes', sa.Column('inputs', postgresql.JSONB(astext_type=sa.Text()), nullable=True, comment='Input properties values'))
+    op.add_column('projects_nodes', sa.Column('inputs_required', postgresql.JSONB(astext_type=sa.Text()), nullable=True, comment='Required input IDs'))
+    op.add_column('projects_nodes', sa.Column('inputs_units', postgresql.JSONB(astext_type=sa.Text()), nullable=True, comment='Input units'))
+    op.add_column('projects_nodes', sa.Column('output_nodes', postgresql.JSONB(astext_type=sa.Text()), nullable=True, comment='Node IDs of those connected to the output'))
+    op.add_column('projects_nodes', sa.Column('outputs', postgresql.JSONB(astext_type=sa.Text()), nullable=True, comment='Output properties values'))
+    op.add_column('projects_nodes', sa.Column('run_hash', sa.String(), nullable=True, comment='HEX digest of the resolved inputs + outputs hash at the time when the last outputs were generated'))
+    op.add_column('projects_nodes', sa.Column('state', postgresql.JSONB(astext_type=sa.Text()), nullable=True, comment='State'))
+    op.add_column('projects_nodes', sa.Column('parent', sa.String(), nullable=True, comment="Parent's (group-nodes) node ID"))
+    op.add_column('projects_nodes', sa.Column('boot_options', postgresql.JSONB(astext_type=sa.Text()), nullable=True, comment="Some services provide alternative parameters to be injected at boot time.The user selection should be stored here, and it will overwrite the services's defaults"))
 
-    # Populate the new columns with data from the workbench
     op.execute(
 """
 UPDATE projects_nodes
@@ -83,10 +80,11 @@ def upgrade():
 AND projects_nodes.node_id = subquery.node_id;
 """
 )
-
+    op.alter_column("projects_nodes", "key", nullable=False)
+    op.alter_column("projects_nodes", "version", nullable=False)
+    op.alter_column("projects_nodes", "label", nullable=False)
 
 def downgrade():
-    # ### commands auto generated by Alembic - please adjust! ###
     op.drop_column('projects_nodes', 'boot_options')
     op.drop_column('projects_nodes', 'parent')
     op.drop_column('projects_nodes', 'state')
@@ -103,4 +101,3 @@ def downgrade():
     op.drop_column('projects_nodes', 'label')
     op.drop_column('projects_nodes', 'version')
     op.drop_column('projects_nodes', 'key')
-    # ### end Alembic commands ###

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

@@ -25,7 +25,7 @@
         nullable=False,
         autoincrement=True,
         primary_key=True,
-        doc="Project node index",
+        comment="Index of the project node",
     ),
     sa.Column(
         "project_uuid",
@@ -38,21 +38,21 @@
         ),
         nullable=False,
         index=True,
-        doc="Project unique identifier",
+        comment="Unique identifier of the project",
     ),
     sa.Column(
         "node_id",
         sa.String,
         nullable=False,
         index=True,
-        doc="Node unique identifier",
+        comment="Unique identifier of the node",
     ),
     sa.Column(
         "required_resources",
         JSONB,
         nullable=False,
         server_default=sa.text("'{}'::jsonb"),
-        doc="Node required resources",
+        comment="Required resources",
     ),
     # TIME STAMPS ----
     column_created_datetime(timezone=True),
@@ -61,97 +61,97 @@
         "key",
         sa.String,
         nullable=False,
-        doc="Distinctive name for the node based on the docker registry path",
+        comment="Distinctive name (based on the Docker registry path)",
     ),
     sa.Column(
         "version",
         sa.String,
         nullable=False,
-        doc="Semantic version number of the node",
+        comment="Semantic version number",
     ),
     sa.Column(
         "label",
         sa.String,
         nullable=False,
-        doc="Short name of the node",
+        comment="Short name ",
     ),
     sa.Column(
         "progress",
         sa.Numeric,
         nullable=True,
-        doc="Node progress value",
+        comment="Progress value",
     ),
     sa.Column(
         "thumbnail",
         sa.String,
         nullable=True,
-        doc="Url of the latest screenshot of the node",
+        comment="Url of the latest screenshot",
     ),
     sa.Column(
         "input_access",
         JSONB,
         nullable=True,
-        doc="Map with key - access level pairs",
+        comment="Map with key - access level pairs",
     ),
     sa.Column(
         "input_nodes",
         JSONB,  # Array
         nullable=True,
-        doc="Node IDs of where the node is connected to",
+        comment="IDs of the nodes where is connected to",
     ),
     sa.Column(
         "inputs",
         JSONB,
         nullable=True,
-        doc="Input properties values",
+        comment="Input properties values",
     ),
     sa.Column(
         "inputs_required",
         JSONB,  # Array
         nullable=True,
-        doc="Input IDs that are required",
+        comment="Required input IDs",
     ),
     sa.Column(
         "inputs_units",
         JSONB,
         nullable=True,
-        doc="Input unit values",
+        comment="Input units",
     ),
     sa.Column(
         "output_nodes",
         JSONB,  # Array
         nullable=True,
-        doc="Node IDs of those connected to the output",
+        comment="Node IDs of those connected to the output",
     ),
     sa.Column(
         "outputs",
         JSONB,
         nullable=True,
-        doc="Output properties values",
+        comment="Output properties values",
     ),
     # sa.Column(
     #     "output_node",
     #     sa.BOOLEAN,
     #     nullable=True,
-    #     doc="Deprecated",
+    #     comment="Deprecated",
     # ),
     sa.Column(
         "run_hash",
         sa.String,
         nullable=True,
-        doc="HEX digest of the resolved inputs + outputs hash at the time when the last outputs were generated",
+        comment="HEX digest of the resolved inputs + outputs hash at the time when the last outputs were generated",
     ),
     sa.Column(
         "state",
         JSONB,
         nullable=True,
-        doc="Node state",
+        comment="State",
     ),
     sa.Column(
         "parent",
         sa.String,
         nullable=True,
-        doc="Parent's (group-nodes) node ID",
+        comment="Parent's (group-nodes) node ID",
     ),
     # sa.Column(
     #     "position",
@@ -163,11 +163,10 @@
         "boot_options",
         JSONB,
         nullable=True,
-        doc="Some services provide alternative parameters to be injected at boot time."
+        comment="Some services provide alternative parameters to be injected at boot time."
         "The user selection should be stored here, and it will overwrite the services's defaults",
     ),
     sa.UniqueConstraint("project_uuid", "node_id"),
 )
 
-
 register_modified_datetime_auto_update_trigger(projects_nodes)