@@ -1238,32 +1238,6 @@ mod tests {
1238
1238
) ;
1239
1239
}
1240
1240
1241
- #[ test]
1242
- fn test_invalid_arrow_path ( ) {
1243
- let temp_dir = TempDir :: new ( ) . expect ( "Failed to create temp dir" ) ;
1244
- // Missing the ".data.arrows" suffix
1245
- let filename = "12345abcde&key1=value1.date=2020-01-21.hour=10.minute=30" ;
1246
- let file_path = create_test_file ( & temp_dir, filename) ;
1247
- let random_string = "random123" ;
1248
-
1249
- let result = arrow_path_to_parquet ( & file_path, random_string) ;
1250
-
1251
- assert ! ( result. is_none( ) ) ;
1252
- }
1253
-
1254
- #[ test]
1255
- fn test_invalid_schema_key ( ) {
1256
- let temp_dir = TempDir :: new ( ) . expect ( "Failed to create temp dir" ) ;
1257
- // Invalid schema key with special characters
1258
- let filename = "12345abcde&key1=value1!.date=2020-01-21.hour=10.minute=30.data.arrows" ;
1259
- let file_path = create_test_file ( & temp_dir, filename) ;
1260
- let random_string = "random123" ;
1261
-
1262
- let result = arrow_path_to_parquet ( & file_path, random_string) ;
1263
-
1264
- assert ! ( result. is_none( ) ) ;
1265
- }
1266
-
1267
1241
#[ test]
1268
1242
fn test_complex_path ( ) {
1269
1243
let temp_dir = TempDir :: new ( ) . expect ( "Failed to create temp dir" ) ;
@@ -1289,19 +1263,6 @@ mod tests {
1289
1263
) ;
1290
1264
}
1291
1265
1292
- #[ test]
1293
- fn test_empty_front_part ( ) {
1294
- let temp_dir = TempDir :: new ( ) . expect ( "Failed to create temp dir" ) ;
1295
- // Valid but with empty front part
1296
- let filename = "schema_key..data.arrows" ;
1297
- let file_path = create_test_file ( & temp_dir, filename) ;
1298
- let random_string = "random789" ;
1299
-
1300
- let result = arrow_path_to_parquet ( & file_path, random_string) ;
1301
-
1302
- assert ! ( result. is_none( ) ) ;
1303
- }
1304
-
1305
1266
#[ test]
1306
1267
fn get_or_create_returns_existing_stream ( ) {
1307
1268
let streams = Streams :: default ( ) ;
0 commit comments