diff --git a/operators/salesforce_to_s3_operator.py b/operators/salesforce_to_s3_operator.py
index 366593b..f925013 100644
--- a/operators/salesforce_to_s3_operator.py
+++ b/operators/salesforce_to_s3_operator.py
@@ -223,8 +223,6 @@ def execute(self, context):
                 replace=True
             )
 
-            dest_s3.connection.close()
-
             tmp.close()
 
         logging.info("Query finished!")