From dcc47ee8c16c4d201eb2b222392ab189507f0569 Mon Sep 17 00:00:00 2001 From: Ravi Tiwari Date: Wed, 19 Feb 2020 16:47:38 +0545 Subject: [PATCH] Remove s3 connection close. --- operators/salesforce_to_s3_operator.py | 2 -- 1 file changed, 2 deletions(-) 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!")