(request, azure_server)
| 310 | |
| 311 | @pytest.fixture |
| 312 | def azurefs(request, azure_server): |
| 313 | request.config.pyarrow.requires('azure') |
| 314 | from pyarrow.fs import AzureFileSystem |
| 315 | |
| 316 | host, port, account_name, account_key = azure_server['connection'] |
| 317 | azurite_authority = f"{host}:{port}" |
| 318 | azurite_scheme = "http" |
| 319 | |
| 320 | container = 'pyarrow-filesystem/' |
| 321 | |
| 322 | fs = AzureFileSystem(account_name=account_name, |
| 323 | account_key=account_key, |
| 324 | blob_storage_authority=azurite_authority, |
| 325 | dfs_storage_authority=azurite_authority, |
| 326 | blob_storage_scheme=azurite_scheme, |
| 327 | dfs_storage_scheme=azurite_scheme) |
| 328 | |
| 329 | fs.create_dir(container) |
| 330 | |
| 331 | yield dict( |
| 332 | fs=fs, |
| 333 | pathfn=container.__add__, |
| 334 | allow_move_dir=True, |
| 335 | allow_append_to_file=True, |
| 336 | ) |
| 337 | fs.delete_dir(container) |
| 338 | |
| 339 | |
| 340 | @pytest.fixture |
nothing calls this directly
no test coverage detected