diff --git a/agent/site.py b/agent/site.py index 2d19a8b..2e18f85 100644 --- a/agent/site.py +++ b/agent/site.py @@ -355,7 +355,7 @@ def restore_site_tables(self): output = self.execute( "set -o pipefail && " f"gunzip -c '{backup_file_path}' | " - f"mysql -h {self.host} -u {self.user} -p{self.password} -P {self.port}" + f"mysql -h {self.host} -u {self.user} -p{self.password} -P {self.port} " f"{self.database}", executable="/bin/bash", ) @@ -572,7 +572,7 @@ def restore_touched_tables(self): output = self.execute( "set -o pipefail && " f"gunzip -c '{backup_file}' | " - f"mysql -h {self.host} -u {self.user} -p{self.password} -P {self.port}" + f"mysql -h {self.host} -u {self.user} -p{self.password} -P {self.port} " f"{self.database}", executable="/bin/bash", ) @@ -587,7 +587,7 @@ def drop_new_tables(self): data = {"dropped": {}} for table in new_tables: output = self.execute( - f"mysql -h {self.host} -u {self.user} -p{self.password} -P {self.port}" + f"mysql -h {self.host} -u {self.user} -p{self.password} -P {self.port} " f"{self.database} -e 'DROP TABLE `{table}`'" ) data["dropped"][table] = output @@ -669,7 +669,7 @@ def timezone(self): ) try: timezone = self.execute( - f"mysql -h {self.host} -u{self.database} -p{self.password} -P {self.port}" + f"mysql -h {self.host} -u{self.database} -p{self.password} -P {self.port} " f'-sN -e "{query}"' )["output"].strip() except Exception: