diff --git a/pulsar/client/transport/tus.py b/pulsar/client/transport/tus.py index fc60939d..209cf64d 100644 --- a/pulsar/client/transport/tus.py +++ b/pulsar/client/transport/tus.py @@ -10,7 +10,6 @@ tus_client_available = True except ImportError: tus_client_available = False - client = None TUS_CLIENT_UNAVAILABLE_MESSAGE = \ "You are attempting to use the Tus transport with the Pulsar client but tuspy is unavailable." @@ -39,7 +38,6 @@ def tus_upload_file(url: str, path: str) -> None: post_response.raise_for_status() - def find_tus_endpoint(job_files_endpoint: str) -> str: parsed = urlparse(job_files_endpoint) job_files_url_path = parsed.path diff --git a/requirements.txt b/requirements.txt index de27a41c..1db30fa4 100644 --- a/requirements.txt +++ b/requirements.txt @@ -10,6 +10,7 @@ paramiko typing-extensions pydantic-tes>=0.1.5 pyjwt +tuspy ## Uncomment if using DRMAA queue manager. #drmaa