22
22
volume_size = 10
23
23
commercial_type = "DEV1-S"
24
24
zone = "fr-par-1"
25
- timeout_attach = 10
26
25
27
26
28
27
class TestE2EServerCreation (unittest .TestCase ):
@@ -43,19 +42,24 @@ def tearDown(self) -> None:
43
42
44
43
self .blockAPI .delete_volume (volume_id = volume .id )
45
44
logger .info ("✅ Volume {volume.id} has been deleted" )
45
+
46
46
if self ._server :
47
47
self .instanceAPI .delete_server (zone = self .zone , server_id = self ._server .id )
48
48
logger .info (f"🗑️ Deleted server: { self ._server .id } " )
49
49
50
50
def wait_test_instance_server (self , server_id ):
51
51
interval = interval
52
+
52
53
for i in range (1 , max_retry ):
53
54
interval *= i
54
55
s = self .instanceAPI .get_server (zone = self .zone , server_id = server_id )
56
+
55
57
if s .state == "running" :
56
58
logger .info (f"✅ Server { server_id } is running." )
57
59
break
60
+
58
61
time .sleep (interval )
62
+
59
63
self .fail ("Server did not reach 'running' state in time." )
60
64
61
65
def create_test_instance_server (self ) -> Server :
@@ -72,18 +76,23 @@ def create_test_instance_server(self) -> Server:
72
76
volumes = volume ,
73
77
)
74
78
logger .info (f"✅ Created server: { server .id } " )
79
+
75
80
self ._server = server .server
76
81
self .wait_test_instance_server (server_id = server .server .id )
82
+
77
83
return server .server
78
84
79
85
def create_test_from_empty_volume (self , number ) -> List [Volume ]:
80
86
volumes : List [Volume ] = {}
87
+
81
88
for i in range (number ):
82
89
volume = self .blockAPI .create_volume (
83
90
from_empty = CreateVolumeRequestFromEmpty (size = 10 ),
84
91
)
85
92
logger .info ("✅ Created server: {volume.id}" )
93
+
86
94
self .blockAPI .wait_for_volume (volume_id = volume .id , zone = self .zone )
95
+
87
96
self ._volumes .append (volume ) # Ensure cleanup in tearDown
88
97
volumes .append (volume )
89
98
0 commit comments