Skip to content

Commit

Permalink
fix lint
Browse files Browse the repository at this point in the history
  • Loading branch information
TangSiyang2001 committed Feb 25, 2024
1 parent 32a024a commit 8b5ec97
Showing 1 changed file with 7 additions and 4 deletions.
11 changes: 7 additions & 4 deletions python/pyarrow/tests/test_fs.py
Original file line number Diff line number Diff line change
Expand Up @@ -1905,21 +1905,24 @@ def test_s3_finalize_region_resolver():
"""
subprocess.check_call([sys.executable, "-c", code])


@pytest.mark.s3
def test_concurrent_fs_init():
code = """if 1:
import threading
import pytest
from pyarrow.fs import (FileSystem, S3FileSystem
ensure_s3_initialized, finalize_s3)
from pyarrow.fs import (FileSystem, S3FileSystem,
ensure_s3_initialized, finalize_s3)
threads = []
fn = lambda: FileSystem.from_uri('s3://mf-nwp-models/README.txt')
for i in range(4):
thread = threading.Thread(target = lambda: FileSystem.from_uri('s3://mf-nwp-models/README.txt'))
thread = threading.Thread(target = fn)
threads.append(thread)
thread.start()
for thread in threads:
thread.join()
finalize_s3()
"""
"""
subprocess.check_call([sys.executable, "-c", code])

0 comments on commit 8b5ec97

Please sign in to comment.