3636from pssh .utils import load_private_key
3737from embedded_server .embedded_server import start_server , make_socket , \
3838 logger as server_logger , paramiko_logger , start_server_from_ip
39- from embedded_server . fake_agent import FakeAgent
39+ from pssh . agent import SSHAgent
4040from paramiko import RSAKey
4141
4242PKEY_FILENAME = os .path .sep .join ([os .path .dirname (__file__ ), 'test_client_private_key' ])
@@ -57,7 +57,7 @@ def setUp(self):
5757 self .server_sock = make_socket (self .host )
5858 self .listen_port = self .server_sock .getsockname ()[1 ]
5959 self .server = start_server (self .server_sock )
60- self .agent = FakeAgent ()
60+ self .agent = SSHAgent ()
6161 self .agent .add_key (USER_KEY )
6262 self .client = ParallelSSHClient ([self .host ], port = self .listen_port ,
6363 pkey = self .user_key ,
@@ -73,6 +73,7 @@ def make_random_port(self, host=None):
7373 def tearDown (self ):
7474 del self .client
7575 self .server .kill ()
76+ del self .agent
7677
7778 def test_pssh_client_no_stdout_non_zero_exit_code_immediate_exit (self ):
7879 output = self .client .run_command ('exit 1' )
@@ -533,7 +534,6 @@ def test_ssh_proxy(self):
533534 self .server .kill ()
534535 server , _ = start_server_from_ip (self .host , port = self .listen_port )
535536 proxy_host = '127.0.0.2'
536- proxy_server_port = self .make_random_port (proxy_host )
537537 proxy_server , proxy_server_port = start_server_from_ip (proxy_host )
538538 client = ParallelSSHClient ([self .host ], port = self .listen_port ,
539539 pkey = self .user_key ,
0 commit comments