Adding support for ssh key and passphrase

CHANGELOG.md

@@ -1,3 +1,9 @@
+# [0.1.3] 12/09/2022
+
+## Added
+
+ - support for ssh key and passphrase
+
 # [0.1.0] 12/09/2022
 
 Initial release

fs_task_queue/plugins/ssh.py

@@ -73,6 +73,8 @@ def _create_client(self, directory):
             "port": int(p.port or 22),
             "username": p.username or os.getlogin(),
             "password": p.password,
+            "key_file": os.environ.get('PARAMIKO_SSH_KEYFILE'),
+            "passphrase": os.environ.get('PARAMIKO_SSH_PASSPHRASE'),
             "path": p.path,
         }
 
@@ -83,6 +85,8 @@ def _create_client(self, directory):
             port=params["port"],
             username=params["username"],
             password=params["password"],
+            key_file=params["key_file"],
+            passphrase=params["passphrase"],
         )
         self._sftp_client = self._ssh_client.open_sftp()
         return pathlib.Path(params["path"])

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "fs-task-queue"
-version = "0.1.2"
+version = "0.1.3"
 description = "Filesystem based task queue"
 readme = "README.md"
 requires-python = ">=3.7"