|
|
@ -314,8 +314,9 @@ class DbTransfer(TransferBase): |
|
|
|
except Exception as e: |
|
|
|
logging.error(e) |
|
|
|
update_transfer = {} |
|
|
|
|
|
|
|
finally: |
|
|
|
conn.close() |
|
|
|
|
|
|
|
return update_transfer |
|
|
|
|
|
|
|
def pull_db_all_user(self): |
|
|
@ -333,9 +334,7 @@ class DbTransfer(TransferBase): |
|
|
|
|
|
|
|
try: |
|
|
|
rows = self.pull_db_users(conn) |
|
|
|
except Exception as e: |
|
|
|
logging.error(e) |
|
|
|
rows = [] |
|
|
|
finally: |
|
|
|
conn.close() |
|
|
|
|
|
|
|
if not rows: |
|
|
|