Skip to content

Commit bdd0da7

Browse files
committed
Don't reuse ZstdCompressor to make SDK thread safe
1 parent 558b7c0 commit bdd0da7

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

lightspark/requests/requester.py

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -12,10 +12,8 @@
1212

1313
try:
1414
from zstandard import ZstdCompressor
15-
16-
zstd: Optional[ZstdCompressor] = ZstdCompressor()
1715
except ImportError:
18-
zstd = None
16+
ZstdCompressor = None
1917

2018
import requests
2119
from requests.auth import HTTPBasicAuth
@@ -86,8 +84,8 @@ def execute_graphql(
8684
"X-Lightspark-SDK": user_agent,
8785
}
8886
if len(payload) > 1024:
89-
if zstd:
90-
payload = zstd.compress(payload)
87+
if ZstdCompressor:
88+
payload = ZstdCompressor().compress(payload)
9189
headers["Content-Encoding"] = "zstd"
9290
else:
9391
payload = zlib.compress(payload, level=zlib.Z_BEST_SPEED)

0 commit comments

Comments
 (0)