@@ -131,7 +131,7 @@ def setup_method(self):
131
131
132
132
@pytest .fixture ()
133
133
def storage_client (self ):
134
- yield storage .Client (project = e2e_base . _PROJECT )
134
+ yield storage .Client (project = _TEST_PROJECT )
135
135
136
136
@pytest .fixture ()
137
137
def staging_bucket (self , storage_client ):
@@ -174,7 +174,7 @@ def test_get_new_dataset_and_import(self, dataset_gapic_client):
174
174
175
175
try :
176
176
text_dataset = aiplatform .TextDataset .create (
177
- display_name = f"temp_sdk_integration_test_create_text_dataset_ { uuid . uuid4 () } " ,
177
+ display_name = self . _make_display_name ( key = "get_new_dataset_and_import" ) ,
178
178
)
179
179
180
180
my_dataset = aiplatform .TextDataset (dataset_name = text_dataset .name )
@@ -189,7 +189,6 @@ def test_get_new_dataset_and_import(self, dataset_gapic_client):
189
189
my_dataset .import_data (
190
190
gcs_source = _TEST_TEXT_ENTITY_EXTRACTION_GCS_SOURCE ,
191
191
import_schema_uri = _TEST_TEXT_ENTITY_IMPORT_SCHEMA ,
192
- import_request_timeout = 600.0 ,
193
192
)
194
193
195
194
data_items_post_import = dataset_gapic_client .list_data_items (
@@ -198,8 +197,7 @@ def test_get_new_dataset_and_import(self, dataset_gapic_client):
198
197
199
198
assert len (list (data_items_post_import )) == 469
200
199
finally :
201
- if text_dataset is not None :
202
- text_dataset .delete ()
200
+ text_dataset .delete ()
203
201
204
202
@vpcsc_config .skip_if_inside_vpcsc
205
203
def test_create_and_import_image_dataset (self , dataset_gapic_client ):
@@ -208,7 +206,9 @@ def test_create_and_import_image_dataset(self, dataset_gapic_client):
208
206
209
207
try :
210
208
img_dataset = aiplatform .ImageDataset .create (
211
- display_name = f"temp_sdk_integration_create_and_import_dataset_{ uuid .uuid4 ()} " ,
209
+ display_name = self ._make_display_name (
210
+ key = "create_and_import_image_dataset"
211
+ ),
212
212
gcs_source = _TEST_IMAGE_OBJECT_DETECTION_GCS_SOURCE ,
213
213
import_schema_uri = _TEST_IMAGE_OBJ_DET_IMPORT_SCHEMA ,
214
214
create_request_timeout = None ,
@@ -230,7 +230,7 @@ def test_create_tabular_dataset(self):
230
230
231
231
try :
232
232
tabular_dataset = aiplatform .TabularDataset .create (
233
- display_name = f"temp_sdk_integration_create_and_import_dataset_ { uuid . uuid4 () } " ,
233
+ display_name = self . _make_display_name ( key = "create_tabular_dataset" ) ,
234
234
gcs_source = [_TEST_TABULAR_CLASSIFICATION_GCS_SOURCE ],
235
235
create_request_timeout = None ,
236
236
)
@@ -250,13 +250,15 @@ def test_create_tabular_dataset(self):
250
250
tabular_dataset .delete ()
251
251
252
252
def test_create_tabular_dataset_from_dataframe (self , bigquery_dataset ):
253
- bq_staging_table = f"bq://{ e2e_base . _PROJECT } .{ bigquery_dataset .dataset_id } .test_table{ uuid .uuid4 ()} "
253
+ bq_staging_table = f"bq://{ _TEST_PROJECT } .{ bigquery_dataset .dataset_id } .test_table{ uuid .uuid4 ()} "
254
254
255
255
try :
256
256
tabular_dataset = aiplatform .TabularDataset .create_from_dataframe (
257
257
df_source = _TEST_DATAFRAME ,
258
258
staging_path = bq_staging_table ,
259
- display_name = f"temp_sdk_integration_create_and_import_dataset_from_dataframe{ uuid .uuid4 ()} " ,
259
+ display_name = self ._make_display_name (
260
+ key = "create_and_import_dataset_from_dataframe"
261
+ ),
260
262
)
261
263
262
264
"""Use the Dataset.create_from_dataframe() method to create a new tabular dataset.
@@ -281,12 +283,14 @@ def test_create_tabular_dataset_from_dataframe_with_provided_schema(
281
283
created and references the BQ source."""
282
284
283
285
try :
284
- bq_staging_table = f"bq://{ e2e_base . _PROJECT } .{ bigquery_dataset .dataset_id } .test_table{ uuid .uuid4 ()} "
286
+ bq_staging_table = f"bq://{ _TEST_PROJECT } .{ bigquery_dataset .dataset_id } .test_table{ uuid .uuid4 ()} "
285
287
286
288
tabular_dataset = aiplatform .TabularDataset .create_from_dataframe (
287
289
df_source = _TEST_DATAFRAME ,
288
290
staging_path = bq_staging_table ,
289
- display_name = f"temp_sdk_integration_create_and_import_dataset_from_dataframe{ uuid .uuid4 ()} " ,
291
+ display_name = self ._make_display_name (
292
+ key = "create_and_import_dataset_from_dataframe"
293
+ ),
290
294
bq_schema = _TEST_DATAFRAME_BQ_SCHEMA ,
291
295
)
292
296
0 commit comments