Skip to content

Commit 8e665ad

Browse files
add SalesforceToS3 Operator and remove S3ToRedshift
1 parent 94bed81 commit 8e665ad

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

__init__.py

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,18 @@
11
from airflow.plugins_manager import AirflowPlugin
22
from hooks.salesforce_hook import SalesforceHook
3-
from operators.s3_to_redshift_operator import S3ToRedshiftOperator
43
from operators.salesforce_schema_to_redshift_operator import SalesforceSchemaToRedshiftOperator
54
from operators.salesforce_to_s3_operator import SalesforceBulkQueryToS3Operator
5+
from operators.salesforce_to_s3_operator import SalesforceToS3Operator
6+
67

78
class SalesforceToRedshiftPlugin(AirflowPlugin):
89
name = "salesforce_to_redshift_plugin"
910
hooks = [SalesforceHook]
10-
operators = [S3ToRedshiftOperator, SalesforceSchemaToRedshiftOperator, SalesforceBulkQueryToS3Operator]
11+
operators = [SalesforceToS3Operator,
12+
SalesforceSchemaToRedshiftOperator,
13+
SalesforceBulkQueryToS3Operator]
1114
executors = []
1215
macros = []
1316
admin_views = []
1417
flask_blueprints = []
15-
menu_links = []
18+
menu_links = []

0 commit comments

Comments
 (0)