diff --git a/migrations/versions/schema/2023-01-16_69a2eb84aae4_add_workflows.py b/migrations/versions/schema/2023-01-16_84775104d8b7_add_workflows.py similarity index 92% rename from migrations/versions/schema/2023-01-16_69a2eb84aae4_add_workflows.py rename to migrations/versions/schema/2023-01-16_84775104d8b7_add_workflows.py index 274fd5e8a97bacefcea9b4ea324b6fbd829afbbb..179d8c5c21fa1e374da1298e9cbceb153b0306a8 100644 --- a/migrations/versions/schema/2023-01-16_69a2eb84aae4_add_workflows.py +++ b/migrations/versions/schema/2023-01-16_84775104d8b7_add_workflows.py @@ -1,8 +1,8 @@ """add workflows. -Revision ID: 69a2eb84aae4 -Revises: b815abc87ce9 -Create Date: 2023-01-16 08:33:12.302351 +Revision ID: 84775104d8b7 +Revises: fd8a080b155f +Create Date: 2023-01-16 11:53:24.323119 """ import sqlalchemy as sa @@ -11,8 +11,8 @@ from orchestrator.migrations.helpers import create_workflow, delete_workflow from orchestrator.targets import Target # revision identifiers, used by Alembic. -revision = '69a2eb84aae4' -down_revision = 'b815abc87ce9' +revision = '84775104d8b7' +down_revision = 'fd8a080b155f' branch_labels = None depends_on = None @@ -86,3 +86,4 @@ def downgrade() -> None: conn = op.get_bind() for workflow in new_workflows: delete_workflow(conn, workflow["name"]) + diff --git a/migrations/versions/schema/2023-01-12_b815abc87ce9_add_node_linecard_and_port_products.py b/migrations/versions/schema/2023-01-16_fd8a080b155f_add_node_linecard_and_port_products.py similarity index 85% rename from migrations/versions/schema/2023-01-12_b815abc87ce9_add_node_linecard_and_port_products.py rename to migrations/versions/schema/2023-01-16_fd8a080b155f_add_node_linecard_and_port_products.py index b4df140f4183e6197146f1d2931ed97fb39f063c..e4270daefd6fc7375177601024cb83dc5eab1857 100644 --- a/migrations/versions/schema/2023-01-12_b815abc87ce9_add_node_linecard_and_port_products.py +++ b/migrations/versions/schema/2023-01-16_fd8a080b155f_add_node_linecard_and_port_products.py @@ -1,15 +1,15 @@ """Add Node, LineCard, and Port products. -Revision ID: b815abc87ce9 +Revision ID: fd8a080b155f Revises: -Create Date: 2023-01-12 12:35:30.770774 +Create Date: 2023-01-16 11:51:13.092461 """ import sqlalchemy as sa from alembic import op # revision identifiers, used by Alembic. -revision = 'b815abc87ce9' +revision = 'fd8a080b155f' down_revision = None branch_labels = ('data',) depends_on = 'bed6bc0b197a' @@ -18,22 +18,22 @@ depends_on = 'bed6bc0b197a' def upgrade() -> None: conn = op.get_bind() conn.execute(""" -INSERT INTO products (name, description, product_type, tag, status) VALUES ('Node 62.40.96.28', 'Juniper router mx1.lab', 'Node', 'NODE_MX1_LAB', 'active') RETURNING products.product_id +INSERT INTO products (name, description, product_type, tag, status) VALUES ('Node 62.40.96.28', 'Juniper router mx2.lab', 'Node', 'NODE_MX2_LAB', 'active') RETURNING products.product_id """) conn.execute(""" -INSERT INTO products (name, description, product_type, tag, status) VALUES ('Line card CASJ9993', 'Line card in mx1.lab', 'LineCard', 'LINE_CARD_CASJ9993', 'active') RETURNING products.product_id +INSERT INTO products (name, description, product_type, tag, status) VALUES ('Line card CASJ9993', 'Line card in mx2-.lab', 'LineCard', 'LINE_CARD_CASJ9993', 'active') RETURNING products.product_id """) conn.execute(""" -INSERT INTO products (name, description, product_type, tag, status) VALUES ('Line card CARK6375', 'Line card in mx1.lab', 'LineCard', 'LINE_CARD_CARK6375', 'active') RETURNING products.product_id +INSERT INTO products (name, description, product_type, tag, status) VALUES ('Line card CARK6375', 'Line card in mx2.lab', 'LineCard', 'LINE_CARD_CARK6375', 'active') RETURNING products.product_id """) conn.execute(""" -INSERT INTO products (name, description, product_type, tag, status) VALUES ('Port 40GE', 'Port speed capability 40GE+', 'Port', 'PORT_40GE', 'active') RETURNING products.product_id +INSERT INTO products (name, description, product_type, tag, status) VALUES ('Port 40GE', 'Port speed capability 40GE', 'Port', 'PORT_40GE', 'active') RETURNING products.product_id """) conn.execute(""" INSERT INTO products (name, description, product_type, tag, status) VALUES ('Port 4x10GE', 'Port speed capability 4x10GE', 'Port', 'PORT_4x10GE', 'active') RETURNING products.product_id """) conn.execute(""" -INSERT INTO products (name, description, product_type, tag, status) VALUES ('Port 100GE', 'Port speed capability 100GE', 'Port', 'PORT_10GE0GE', 'active') RETURNING products.product_id +INSERT INTO products (name, description, product_type, tag, status) VALUES ('Port 100GE', 'Port speed capability 100GE', 'Port', 'PORT_100GE', 'active') RETURNING products.product_id """) conn.execute(""" INSERT INTO products (name, description, product_type, tag, status) VALUES ('Port 4x25GE', 'Product speed capability 4x25GE', 'Port', 'PORT_4x25GE', 'active') RETURNING products.product_id @@ -69,7 +69,7 @@ INSERT INTO resource_types (resource_type, description) VALUES ('line_card_id', INSERT INTO product_product_blocks (product_id, product_block_id) VALUES ((SELECT products.product_id FROM products WHERE products.name IN ('Node 62.40.96.28')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('NodeBlock'))) """) conn.execute(""" -INSERT INTO product_product_blocks (product_id, product_block_id) VALUES ((SELECT products.product_id FROM products WHERE products.name IN ('Line card CASJ9993')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Line card CARK6375')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 4x10GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 100GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 4x25GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 40GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))) +INSERT INTO product_product_blocks (product_id, product_block_id) VALUES ((SELECT products.product_id FROM products WHERE products.name IN ('Port 40GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 4x25GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 100GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Port 4x10GE')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Line card CARK6375')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))), ((SELECT products.product_id FROM products WHERE products.name IN ('Line card CASJ9993')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock'))) """) conn.execute(""" INSERT INTO product_block_relations (in_use_by_id, depends_on_id) VALUES ((SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('NodeBlock'))) @@ -106,7 +106,7 @@ DELETE FROM resource_types WHERE resource_types.resource_type IN ('node_id', 'li DELETE FROM product_product_blocks WHERE product_product_blocks.product_id IN (SELECT products.product_id FROM products WHERE products.name IN ('Node 62.40.96.28')) AND product_product_blocks.product_block_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('NodeBlock')) """) conn.execute(""" -DELETE FROM product_product_blocks WHERE product_product_blocks.product_id IN (SELECT products.product_id FROM products WHERE products.name IN ('Line card CASJ9993', 'Line card CARK6375', 'Port 4x10GE', 'Port 100GE', 'Port 4x25GE', 'Port 40GE')) AND product_product_blocks.product_block_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock')) +DELETE FROM product_product_blocks WHERE product_product_blocks.product_id IN (SELECT products.product_id FROM products WHERE products.name IN ('Port 40GE', 'Port 4x25GE', 'Port 100GE', 'Port 4x10GE', 'Line card CARK6375', 'Line card CASJ9993')) AND product_product_blocks.product_block_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock')) """) conn.execute(""" DELETE FROM product_block_relations WHERE product_block_relations.in_use_by_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock')) AND product_block_relations.depends_on_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('NodeBlock')) @@ -133,23 +133,23 @@ DELETE FROM subscription_instances WHERE subscription_instances.product_block_id DELETE FROM product_blocks WHERE product_blocks.name IN ('LineCardBlock', 'NodeBlock') """) conn.execute(""" -DELETE FROM products WHERE products.name = 'Line card CASJ9993' +DELETE FROM products WHERE products.name = 'Port 40GE' """) conn.execute(""" -DELETE FROM products WHERE products.name = 'Line card CARK6375' +DELETE FROM products WHERE products.name = 'Port 4x25GE' """) conn.execute(""" -DELETE FROM products WHERE products.name = 'Port 4x10GE' +DELETE FROM products WHERE products.name = 'Port 100GE' """) conn.execute(""" -DELETE FROM products WHERE products.name = 'Port 100GE' +DELETE FROM products WHERE products.name = 'Port 4x10GE' """) conn.execute(""" -DELETE FROM products WHERE products.name = 'Node 62.40.96.28' +DELETE FROM products WHERE products.name = 'Line card CARK6375' """) conn.execute(""" -DELETE FROM products WHERE products.name = 'Port 4x25GE' +DELETE FROM products WHERE products.name = 'Node 62.40.96.28' """) conn.execute(""" -DELETE FROM products WHERE products.name = 'Port 40GE' +DELETE FROM products WHERE products.name = 'Line card CASJ9993' """)