Merge pull request #30 from singer-io/stop-streaming

Read the dataset into memory

tap_salesforce/salesforce/bulk.py

@@ -239,7 +239,8 @@ def get_batch_results(self, job_id, batch_id, catalog_entry):
 
             with metrics.http_request_timer("batch_result") as timer:
                 timer.tags['sobject'] = catalog_entry['stream']
-                result_response = self.sf._make_request('GET', url, headers=headers, stream=True)
+                # Removed the stream=True param because Salesforce was snapping open connections
+                result_response = self.sf._make_request('GET', url, headers=headers)
 
             # Starting with a streaming generator, replace any NULL bytes in the line given by the CSV reader
             streaming_response = self._iter_lines(result_response)