@@ -68,6 +68,10 @@ def _get_client():
68
68
return bigquery .Client (project = project_id , credentials = credentials )
69
69
70
70
71
+ def generate_rand_str (length : int = 10 ) -> str :
72
+ return "" .join (random .choices (string .ascii_lowercase , k = length ))
73
+
74
+
71
75
def make_mixed_dataframe_v2 (test_size ):
72
76
# create df to test for all BQ datatypes except RECORD
73
77
bools = np .random .randint (2 , size = (1 , test_size )).astype (bool )
@@ -153,19 +157,15 @@ def gbq_dataset(self):
153
157
_skip_if_no_project_id ()
154
158
_skip_if_no_private_key_path ()
155
159
156
- dataset_id = "pydata_pandas_bq_testing_py31"
160
+ dataset_id = "pydata_pandas_bq_testing_" + generate_rand_str ()
157
161
158
162
self .client = _get_client ()
159
163
self .dataset = self .client .dataset (dataset_id )
160
- try :
161
- # Clean-up previous test runs.
162
- self .client .delete_dataset (self .dataset , delete_contents = True )
163
- except api_exceptions .NotFound :
164
- pass # It's OK if the dataset doesn't already exist.
165
164
165
+ # Create the dataset
166
166
self .client .create_dataset (bigquery .Dataset (self .dataset ))
167
167
168
- table_name = "" . join ( random . choices ( string . ascii_lowercase , k = 10 ) )
168
+ table_name = generate_rand_str ( )
169
169
destination_table = f"{ dataset_id } .{ table_name } "
170
170
yield destination_table
171
171
0 commit comments