diff --git a/gso/migrations/versions/2023-04-21_d3616a686094_add_iptrunk_create_workflow.py b/gso/migrations/versions/2023-04-24_37a3dcdcb110_add_iptrunk_create_workflows.py
similarity index 78%
rename from gso/migrations/versions/2023-04-21_d3616a686094_add_iptrunk_create_workflow.py
rename to gso/migrations/versions/2023-04-24_37a3dcdcb110_add_iptrunk_create_workflows.py
index 0380996f37ec80ff32dc8ff855640ca3fb7bcec1..681eb89df05ff3738b3bda1bea6b90b23ae7a63a 100644
--- a/gso/migrations/versions/2023-04-21_d3616a686094_add_iptrunk_create_workflow.py
+++ b/gso/migrations/versions/2023-04-24_37a3dcdcb110_add_iptrunk_create_workflows.py
@@ -1,16 +1,16 @@
-"""add Iptrunk create  workflow.
+"""add IPtrunk create workflows.
 
-Revision ID: d3616a686094
-Revises: 42d52099c7da
-Create Date: 2023-04-21 12:22:18.243625
+Revision ID: 37a3dcdcb110
+Revises: e13448650548
+Create Date: 2023-04-24 13:19:58.545357
 
 """
 import sqlalchemy as sa
 from alembic import op
 
 # revision identifiers, used by Alembic.
-revision = 'd3616a686094'
-down_revision = '42d52099c7da'
+revision = '37a3dcdcb110'
+down_revision = 'e13448650548'
 branch_labels = None
 depends_on = None
 
diff --git a/gso/migrations/versions/2023-04-21_42d52099c7da_add_iptrunk_product.py b/gso/migrations/versions/2023-04-24_e13448650548_add_iptrunk_product.py
similarity index 86%
rename from gso/migrations/versions/2023-04-21_42d52099c7da_add_iptrunk_product.py
rename to gso/migrations/versions/2023-04-24_e13448650548_add_iptrunk_product.py
index c4a0b09e992b3a4e1fd7430825b22e60f5ec1315..a14cb52d2db49da23a5e5756e1a8e47fb5e7c05f 100644
--- a/gso/migrations/versions/2023-04-21_42d52099c7da_add_iptrunk_product.py
+++ b/gso/migrations/versions/2023-04-24_e13448650548_add_iptrunk_product.py
@@ -1,15 +1,15 @@
 """Add Iptrunk product.
 
-Revision ID: 42d52099c7da
+Revision ID: e13448650548
 Revises: 857225661207
-Create Date: 2023-04-21 12:04:20.186345
+Create Date: 2023-04-24 13:16:38.724103
 
 """
 import sqlalchemy as sa
 from alembic import op
 
 # revision identifiers, used by Alembic.
-revision = '42d52099c7da'
+revision = 'e13448650548'
 down_revision = '857225661207'
 branch_labels = None
 depends_on = None
@@ -21,49 +21,49 @@ def upgrade() -> None:
 INSERT INTO products (name, description, product_type, tag, status) VALUES ('Iptrunk', 'A core link', 'Iptrunk', 'IPTRUNK', 'active') RETURNING products.product_id
     """)
     conn.execute("""
-INSERT INTO fixed_inputs (name, value, product_id) VALUES ('iptrunk_type', 'Leased line vs dark fiber', (SELECT products.product_id FROM products WHERE products.name IN ('Iptrunk')))
+INSERT INTO product_blocks (name, description, tag, status) VALUES ('IptrunkBlock', 'IP trunk block', 'IPTRUNK', 'active') RETURNING product_blocks.product_block_id
     """)
     conn.execute("""
-INSERT INTO product_blocks (name, description, tag, status) VALUES ('IptrunkBlock', 'An IPtrunk', 'IPTRUNK', 'active') RETURNING product_blocks.product_block_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideB_fqdn', 'FQDN side B') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_ipv4_network', 'The IPv4 network to be used on the trunk') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_speed', 'Speed of trunk members') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideB_ae_iface', 'AE interface name on B side') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideB_ae_iface', 'AE side B') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideB_ae_members', 'Members of AE interface on B side') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideB_ae_geant_a_sid', 'GA-SID side B') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideA_fqdn', 'Name of the router on A side') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_type', 'leased vs darkfiber') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_minimum_links', 'Minimum links of the trunk') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideA_ae_geant_a_sid', 'GA-SID side A') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideB_fqdn', 'Name of the router on B side') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_ipv4_network', 'IPv4 network for the trunk') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('geant_s_sid', 'Geant Service ID') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('geant_s_sid', 'GS SID for trunk') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideA_ae_geant_a_sid', 'Geant Access port ID on A side') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_ipv6_network', 'IPv6 network for the trunk') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_speed', 'Speed of the members of the trunk') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideA_ae_iface', 'AE side A') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_ipv6_network', 'The IPv6 network to be used on the trunk') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideA_fqdn', 'FQDN side A') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideB_ae_geant_a_sid', 'Geant Access port ID on B side') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_minimum_links', 'minimum links') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideA_ae_iface', 'AE interface name on A side') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideB_ae_members', 'side B members') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
-INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideA_ae_members', 'Members of AE interface on A side') RETURNING resource_types.resource_type_id
+INSERT INTO resource_types (resource_type, description) VALUES ('iptrunk_sideA_ae_members', 'side A members') RETURNING resource_types.resource_type_id
     """)
     conn.execute("""
 INSERT INTO product_product_blocks (product_id, product_block_id) VALUES ((SELECT products.product_id FROM products WHERE products.name IN ('Iptrunk')), (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('IptrunkBlock')))
@@ -72,6 +72,9 @@ INSERT INTO product_product_blocks (product_id, product_block_id) VALUES ((SELEC
 INSERT INTO product_block_resource_types (product_block_id, resource_type_id) VALUES ((SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('IptrunkBlock')), (SELECT resource_types.resource_type_id FROM resource_types WHERE resource_types.resource_type IN ('geant_s_sid')))
     """)
     conn.execute("""
+INSERT INTO product_block_resource_types (product_block_id, resource_type_id) VALUES ((SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('IptrunkBlock')), (SELECT resource_types.resource_type_id FROM resource_types WHERE resource_types.resource_type IN ('iptrunk_type')))
+    """)
+    conn.execute("""
 INSERT INTO product_block_resource_types (product_block_id, resource_type_id) VALUES ((SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('IptrunkBlock')), (SELECT resource_types.resource_type_id FROM resource_types WHERE resource_types.resource_type IN ('iptrunk_speed')))
     """)
     conn.execute("""
@@ -118,6 +121,12 @@ DELETE FROM product_block_resource_types WHERE product_block_resource_types.prod
 DELETE FROM subscription_instance_values USING product_block_resource_types WHERE subscription_instance_values.subscription_instance_id IN (SELECT subscription_instances.subscription_instance_id FROM subscription_instances WHERE subscription_instances.subscription_instance_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('IptrunkBlock'))) AND product_block_resource_types.resource_type_id = (SELECT resource_types.resource_type_id FROM resource_types WHERE resource_types.resource_type IN ('geant_s_sid'))
     """)
     conn.execute("""
+DELETE FROM product_block_resource_types WHERE product_block_resource_types.product_block_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('IptrunkBlock')) AND product_block_resource_types.resource_type_id = (SELECT resource_types.resource_type_id FROM resource_types WHERE resource_types.resource_type IN ('iptrunk_type'))
+    """)
+    conn.execute("""
+DELETE FROM subscription_instance_values USING product_block_resource_types WHERE subscription_instance_values.subscription_instance_id IN (SELECT subscription_instances.subscription_instance_id FROM subscription_instances WHERE subscription_instances.subscription_instance_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('IptrunkBlock'))) AND product_block_resource_types.resource_type_id = (SELECT resource_types.resource_type_id FROM resource_types WHERE resource_types.resource_type IN ('iptrunk_type'))
+    """)
+    conn.execute("""
 DELETE FROM product_block_resource_types WHERE product_block_resource_types.product_block_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('IptrunkBlock')) AND product_block_resource_types.resource_type_id = (SELECT resource_types.resource_type_id FROM resource_types WHERE resource_types.resource_type IN ('iptrunk_speed'))
     """)
     conn.execute("""
@@ -190,18 +199,15 @@ DELETE FROM product_block_resource_types WHERE product_block_resource_types.prod
 DELETE FROM subscription_instance_values USING product_block_resource_types WHERE subscription_instance_values.subscription_instance_id IN (SELECT subscription_instances.subscription_instance_id FROM subscription_instances WHERE subscription_instances.subscription_instance_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('IptrunkBlock'))) AND product_block_resource_types.resource_type_id = (SELECT resource_types.resource_type_id FROM resource_types WHERE resource_types.resource_type IN ('iptrunk_sideB_ae_members'))
     """)
     conn.execute("""
-DELETE FROM subscription_instance_values WHERE subscription_instance_values.resource_type_id IN (SELECT resource_types.resource_type_id FROM resource_types WHERE resource_types.resource_type IN ('iptrunk_ipv4_network', 'iptrunk_sideB_ae_iface', 'iptrunk_sideB_ae_members', 'iptrunk_sideA_fqdn', 'iptrunk_minimum_links', 'iptrunk_sideB_fqdn', 'geant_s_sid', 'iptrunk_sideA_ae_geant_a_sid', 'iptrunk_speed', 'iptrunk_ipv6_network', 'iptrunk_sideB_ae_geant_a_sid', 'iptrunk_sideA_ae_iface', 'iptrunk_sideA_ae_members'))
+DELETE FROM subscription_instance_values WHERE subscription_instance_values.resource_type_id IN (SELECT resource_types.resource_type_id FROM resource_types WHERE resource_types.resource_type IN ('iptrunk_sideB_fqdn', 'iptrunk_speed', 'iptrunk_sideB_ae_iface', 'iptrunk_sideB_ae_geant_a_sid', 'iptrunk_type', 'iptrunk_sideA_ae_geant_a_sid', 'iptrunk_ipv4_network', 'geant_s_sid', 'iptrunk_ipv6_network', 'iptrunk_sideA_ae_iface', 'iptrunk_sideA_fqdn', 'iptrunk_minimum_links', 'iptrunk_sideB_ae_members', 'iptrunk_sideA_ae_members'))
     """)
     conn.execute("""
-DELETE FROM resource_types WHERE resource_types.resource_type IN ('iptrunk_ipv4_network', 'iptrunk_sideB_ae_iface', 'iptrunk_sideB_ae_members', 'iptrunk_sideA_fqdn', 'iptrunk_minimum_links', 'iptrunk_sideB_fqdn', 'geant_s_sid', 'iptrunk_sideA_ae_geant_a_sid', 'iptrunk_speed', 'iptrunk_ipv6_network', 'iptrunk_sideB_ae_geant_a_sid', 'iptrunk_sideA_ae_iface', 'iptrunk_sideA_ae_members')
+DELETE FROM resource_types WHERE resource_types.resource_type IN ('iptrunk_sideB_fqdn', 'iptrunk_speed', 'iptrunk_sideB_ae_iface', 'iptrunk_sideB_ae_geant_a_sid', 'iptrunk_type', 'iptrunk_sideA_ae_geant_a_sid', 'iptrunk_ipv4_network', 'geant_s_sid', 'iptrunk_ipv6_network', 'iptrunk_sideA_ae_iface', 'iptrunk_sideA_fqdn', 'iptrunk_minimum_links', 'iptrunk_sideB_ae_members', 'iptrunk_sideA_ae_members')
     """)
     conn.execute("""
 DELETE FROM product_product_blocks WHERE product_product_blocks.product_id IN (SELECT products.product_id FROM products WHERE products.name IN ('Iptrunk')) AND product_product_blocks.product_block_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('IptrunkBlock'))
     """)
     conn.execute("""
-DELETE FROM fixed_inputs WHERE fixed_inputs.product_id IN (SELECT products.product_id FROM products WHERE products.name IN ('Iptrunk')) AND fixed_inputs.name = 'iptrunk_type'
-    """)
-    conn.execute("""
 DELETE FROM subscription_instances WHERE subscription_instances.product_block_id IN (SELECT product_blocks.product_block_id FROM product_blocks WHERE product_blocks.name IN ('IptrunkBlock'))
     """)
     conn.execute("""
diff --git a/gso/products/product_blocks/iptrunk.py b/gso/products/product_blocks/iptrunk.py
index 2c194254236f0bff58e8b9439df6c1188b0dd48a..1dd6f38c5e91fd7e14f50abb5dd57875eeb4f2c2 100644
--- a/gso/products/product_blocks/iptrunk.py
+++ b/gso/products/product_blocks/iptrunk.py
@@ -1,7 +1,7 @@
 from typing import Optional
 
 from orchestrator.domain.base import ProductBlockModel
-from orchestrator.types import SubscriptionLifecycle
+from orchestrator.types import SubscriptionLifecycle, strEnum
 import ipaddress
 
 #  - id: GS-00012
@@ -30,10 +30,15 @@ import ipaddress
 #        port_id: GA-01834
 
 
+class IptrunkType(strEnum):
+    Dark_fiber = "Dark_fiber"
+    Leased = "Leased"
+
 class IptrunkBlockInactive(ProductBlockModel,
                           lifecycle=[SubscriptionLifecycle.INITIAL],
                           product_block_name="IptrunkBlock"):
     geant_s_sid: Optional[str] = None
+    iptrunk_type: Optional[IptrunkType] = None
     iptrunk_speed: Optional[str] = None
     iptrunk_minimum_links: Optional[int] = None
     iptrunk_ipv4_network: Optional[ipaddress.IPv4Network] = None
@@ -53,6 +58,7 @@ class IptrunkBlockInactive(ProductBlockModel,
 class IptrunkBlockProvisioning(IptrunkBlockInactive,
                               lifecycle=[SubscriptionLifecycle.PROVISIONING]):
     geant_s_sid: Optional[str] = None
+    iptrunk_type: Optional[IptrunkType] = None
     iptrunk_speed: Optional[str] = None
     iptrunk_minimum_links: Optional[int] = None
     iptrunk_ipv4_network: Optional[ipaddress.IPv4Network] = None
@@ -72,6 +78,7 @@ class IptrunkBlockProvisioning(IptrunkBlockInactive,
 class IptrunkBlock(IptrunkBlockProvisioning,
                   lifecycle=[SubscriptionLifecycle.ACTIVE]):
     geant_s_sid: str
+    iptrunk_type: IptrunkType
     iptrunk_speed: str
     iptrunk_minimum_links: int
     iptrunk_ipv4_network: ipaddress.IPv4Network
diff --git a/gso/products/product_types/iptrunk.py b/gso/products/product_types/iptrunk.py
index 0ffeec02fe54bdcdd889608a4d5c77ed19c5b299..dbffb8351efc0dd06cac63bb53ff5a0447389620 100644
--- a/gso/products/product_types/iptrunk.py
+++ b/gso/products/product_types/iptrunk.py
@@ -5,22 +5,15 @@ from gso.products.product_blocks.iptrunk \
     import IptrunkBlock, IptrunkBlockInactive, IptrunkBlockProvisioning
 
 
-class IptrunkType(strEnum):
-    Dark_fiber = "Dark_fiber"
-    Leased = "Leased"
-
 
 class IptrunkInactive(SubscriptionModel, is_base=True):
-    iptrunk_type: IptrunkType
     iptrunk: IptrunkBlockInactive
 
 
 class IptrunkProvisioning(IptrunkInactive,
                          lifecycle=[SubscriptionLifecycle.PROVISIONING]):
-    iptrunk_type: IptrunkType
     iptrunk: IptrunkBlockProvisioning
 
 
 class Iptrunk(IptrunkProvisioning, lifecycle=[SubscriptionLifecycle.ACTIVE]):
-    iptrunk_type: IptrunkType
     iptrunk: IptrunkBlock
diff --git a/gso/workflows/iptrunk/create_iptrunk.py b/gso/workflows/iptrunk/create_iptrunk.py
index 4a87ceaa4b0ddb4dc2f8f03e775c666a8e9887eb..fcd7cb25c3bb47948182426711fa3efa0a368343 100644
--- a/gso/workflows/iptrunk/create_iptrunk.py
+++ b/gso/workflows/iptrunk/create_iptrunk.py
@@ -46,7 +46,6 @@ def initial_input_form_generator(product_name: str) -> FormGenerator:
             title = product_name
 
         geant_s_sid: str
-        iptrunk_type: iptrunk.IptrunkType
         iptrunk_speed: str  # This should be an enum: 1/10/100/400
         iptrunk_minimum_links: int
 
@@ -94,7 +93,6 @@ def get_info_from_ipam(subscription: iptrunk.IptrunkInactive) -> State:
 def initialize_subscription(
     subscription: iptrunk.IptrunkInactive,
     geant_s_sid: str,
-    iptrunk_type: iptrunk.IptrunkType, 
     iptrunk_speed: str,
     iptrunk_minimum_links: int,
     iptrunk_sideA_fqdn: str,
@@ -106,7 +104,7 @@ def initialize_subscription(
     iptrunk_sideB_ae_geant_a_sid: str,
     iptrunk_sideB_ae_members: list[str]
 ) -> State:
-    subscription.iptrunk_type = iptrunk_type
+   # subscription.iptrunk_type = iptrunk_type
 
     subscription.iptrunk.geant_s_sid = geant_s_sid
     subscription.iptrunk.iptrunk_speed = iptrunk_speed
@@ -224,7 +222,7 @@ def create_iptrunk():
     return (
         init
         >> create_subscription
-        #>> store_process_subscription(Target.CREATE)
+        >> store_process_subscription(Target.CREATE)
         #>> get_info_from_ipam
         #>> get_snmp_info
         #>> initialize_subscription