6
6
import os
7
7
8
8
9
- from moto import mock_s3
9
+ from moto import mock_aws
10
10
from moto .moto_server .threaded_moto_server import ThreadedMotoServer
11
11
from libcloud .storage .types import Provider
12
12
from libcloud .storage .providers import get_driver
@@ -17,20 +17,20 @@ def s3_base():
17
17
os .environ ["access_key_id" ] = 'access_key'
18
18
os .environ ["secret_access_key" ] = 'secret_key'
19
19
20
- with mock_s3 ():
20
+ with mock_aws ():
21
21
S3Drive = get_driver (Provider .S3 )
22
22
drive = S3Drive ('access_key' , 'secret_key' )
23
-
23
+ print ( 'drive:' , drive )
24
24
yield drive
25
25
26
26
@pytest .mark .skip (reason = "FIX" )
27
27
async def test_ListJupyterDrives_s3_success (jp_fetch , s3_base ):
28
- with mock_s3 ():
28
+ with mock_aws ():
29
29
# extract S3 drive
30
30
drive = s3_base
31
31
32
- test_bucket_name_1 = "jupyter-drives-test-bucket-1 "
33
- test_bucket_name_2 = "jupyter-drives-test-bucket-2 "
32
+ test_bucket_name_1 = "jupyter-drive-bucket1 "
33
+ test_bucket_name_2 = "jupyter-drive-bucket2 "
34
34
35
35
# Create some test containers
36
36
drive .create_container (test_bucket_name_1 )
@@ -42,11 +42,11 @@ async def test_ListJupyterDrives_s3_success(jp_fetch, s3_base):
42
42
# Then
43
43
assert response .code == 200
44
44
payload = json .loads (response .body )
45
- assert "jupyter-drives-test-bucket-1 " in payload ["data" ]
46
- assert "jupyter-drives-test-bucket-2 " in payload ["data" ]
45
+ assert "jupyter-drive-bucket1 " in payload ["data" ]
46
+ assert "jupyter-drive-bucket2 " in payload ["data" ]
47
47
48
48
async def test_ListJupyterDrives_s3_empty_list (jp_fetch , s3_base ):
49
- with mock_s3 ():
49
+ with mock_aws ():
50
50
# extract S3 drive
51
51
drive = s3_base
52
52
@@ -60,7 +60,7 @@ async def test_ListJupyterDrives_s3_empty_list(jp_fetch, s3_base):
60
60
61
61
@pytest .mark .skip (reason = "FIX" )
62
62
async def test_ListJupyterDrives_s3_missing_credentials (jp_fetch , s3_base ):
63
- with mock_s3 ():
63
+ with mock_aws ():
64
64
# When
65
65
with pytest .raises (tornado .web .HTTPError ) as exc_info :
66
66
response = await jp_fetch ("jupyter-drives" , "drives" )
@@ -70,11 +70,11 @@ async def test_ListJupyterDrives_s3_missing_credentials(jp_fetch, s3_base):
70
70
71
71
@pytest .mark .skip (reason = "FIX" )
72
72
async def test_MountJupyterDriveHandler (jp_fetch , s3_base ):
73
- with mock_s3 ():
73
+ with mock_aws ():
74
74
drive = s3_base
75
75
76
76
# Create test container to mount
77
- test_bucket_name_1 = "jupyter-drives-test-bucket-1 "
77
+ test_bucket_name_1 = "jupyter-drive-bucket1 "
78
78
drive .create_container (test_bucket_name_1 )
79
79
80
80
# When
@@ -85,16 +85,16 @@ async def test_MountJupyterDriveHandler(jp_fetch, s3_base):
85
85
86
86
@pytest .mark .skip (reason = "ToBeImplemented" )
87
87
async def test_UnmountJupyterDriveHandler (jp_fetch , s3_base ):
88
- with mock_s3 ():
88
+ with mock_aws ():
89
89
# extract S3 drive
90
90
drive = s3_base
91
91
92
92
# Create test container to mount
93
- test_bucket_name_1 = "jupyter-drives-test-bucket-1 "
93
+ test_bucket_name_1 = "jupyter-drive-bucket1 "
94
94
drive .create_container (test_bucket_name_1 )
95
95
96
96
# When
97
- body = {"drive_name" : "jupyter-drives-test-bucket-1 " , "mount_drive" : "false" }
97
+ body = {"drive_name" : "jupyter-drive-bucket1 " , "mount_drive" : "false" }
98
98
response = await jp_fetch ("jupyter-drives" , "drives" , body = json .dumps (body ), method = "POST" )
99
99
100
100
assert response ["code" ] == 204
0 commit comments