salesforce_plugin
salesforce_plugin copied to clipboard
Move Data From Salesforce -> S3 -> Redshift
This feature adds time selection for salesforce query. The parameters from_date and to_date gives the possibility to users to make smaller queries within their dags and distribute processing in batches...
Since S3Hook doesn't have a connection attribute, this will throw an exception. Link to the Issue: #5 Solution: remove `dest_s3.connection.close()` which was not accessible in airflow 1.9
## 'S3Hook' object has no attribute 'connection' https://github.com/airflow-plugins/salesforce_plugin/blob/7c21346dd0d49f541ca419d766bf41ac4a20e6cd/operators/salesforce_to_s3_operator.py#L226