diff --git a/tasks/system/ssh/change_port.py b/tasks/system/ssh/change_port.py
index 7069dc8..de1ebde 100644
--- a/tasks/system/ssh/change_port.py
+++ b/tasks/system/ssh/change_port.py
@@ -60,14 +60,14 @@ class ServerTask(Task):
         
         if arr_server:
             #dbserver.insert({'server_id': arr_server['id'], 'access_ip': self.data['ip']})
-            server.query('update serverdbtask set ssh_port=%s WHERE id=%s', [arr_server['id']])
+            serverdb.query('update serverdbtask set ssh_port=%s WHERE id=%s', [self.data['ssh_port'], arr_server['id']])
         
         return True
 
     
     def pre_task(self):
 
-        self.commands_to_execute=[['modules/pastafari2/scripts/system/ssh/change_ssh_port.py', '--port=%s' % (self.data['ssh_port'])]]
+        self.commands_to_execute=[['modules/pastafari2/scripts/system/ssh/change_ssh_port.py', '--ssh_port=%s' % (self.data['ssh_port'])]]
         
         return True