diff --git a/pulsar/client/client.py b/pulsar/client/client.py index 484a7390d31d36e1b5bf959eb1d99b8c296267b4..909095919aae89b5f0e9c411702706adff5f48e3 100644 --- a/pulsar/client/client.py +++ b/pulsar/client/client.py @@ -29,9 +29,10 @@ class OutputNotFoundException(Exception): class BaseJobClient(object): def __init__(self, destination_params, job_id): + destination_params = destination_params or {} self.destination_params = destination_params self.job_id = job_id - if "jobs_directory" in (destination_params or {}): + if "jobs_directory" in destination_params: staging_directory = destination_params["jobs_directory"] sep = destination_params.get("remote_sep", os.sep) job_directory = RemoteJobDirectory( @@ -42,11 +43,7 @@ class BaseJobClient(object): else: job_directory = None - if "ssh_key" in (destination_params or {}): - self.ssh_key = destination_params["ssh_key"] - else: - self.ssh_key = None - + self.ssh_key = destination_params.get("ssh_key", None) self.env = destination_params.get("env", []) self.files_endpoint = destination_params.get("files_endpoint", None) self.job_directory = job_directory