|
1 | | -import getpass |
2 | 1 | import os |
3 | 2 | import socket |
4 | 3 | import subprocess |
|
30 | 29 | generate_encrypted_file_with_openssl, |
31 | 30 | decrypt_remote_file_to_string, |
32 | 31 | get_stored_credentials, |
33 | | - store_credentials, |
34 | 32 | ) |
35 | 33 |
|
36 | 34 |
|
@@ -146,7 +144,9 @@ def bteq_operator( |
146 | 144 | if not self.remote_host: |
147 | 145 | if self.sql: |
148 | 146 | bteq_script = prepare_bteq_script_for_local_execution(sql=self.sql) |
149 | | - self.log.debug("Executing BTEQ script with SQL content: %s", bteq_script) |
| 147 | + self.log.debug( |
| 148 | + "Executing BTEQ script with SQL content: %s", bteq_script |
| 149 | + ) |
150 | 150 | return self.execute_bteq_script( |
151 | 151 | bteq_script, |
152 | 152 | self.remote_working_dir, |
@@ -180,7 +180,9 @@ def bteq_operator( |
180 | 180 | teradata_connection_resource=self.teradata_connection_resource, |
181 | 181 | sql=self.sql, |
182 | 182 | ) |
183 | | - self.log.debug("Executing BTEQ script with SQL content: %s", bteq_script) |
| 183 | + self.log.debug( |
| 184 | + "Executing BTEQ script with SQL content: %s", bteq_script |
| 185 | + ) |
184 | 186 | return self.execute_bteq_script( |
185 | 187 | bteq_script, |
186 | 188 | self.remote_working_dir, |
@@ -352,7 +354,6 @@ def execute_bteq_script_at_remote( |
352 | 354 | remote_port, |
353 | 355 | ) |
354 | 356 |
|
355 | | - |
356 | 357 | def _transfer_to_and_execute_bteq_on_remote( |
357 | 358 | self, |
358 | 359 | file_path: str, |
@@ -660,7 +661,9 @@ def _handle_remote_bteq_file( |
660 | 661 | teradata_connection_resource=self.teradata_connection_resource, |
661 | 662 | sql=file_content, |
662 | 663 | ) |
663 | | - self.log.debug("Executing BTEQ script with SQL content: %s", bteq_script) |
| 664 | + self.log.debug( |
| 665 | + "Executing BTEQ script with SQL content: %s", bteq_script |
| 666 | + ) |
664 | 667 | return self.execute_bteq_script_at_remote( |
665 | 668 | bteq_script, |
666 | 669 | self.remote_working_dir, |
|
0 commit comments