Skip to content

Commit a208463

Browse files
authored
Organize S3 Classes in Amazon Provider (#20167)
* Task: Organize S3 Classes in Amazon Provider
1 parent 7c81df6 commit a208463

31 files changed

+1312
-1137
lines changed

airflow/providers/amazon/aws/example_dags/example_s3_bucket.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
from airflow.decorators import task
2121
from airflow.models.dag import DAG
2222
from airflow.providers.amazon.aws.hooks.s3 import S3Hook
23-
from airflow.providers.amazon.aws.operators.s3_bucket import S3CreateBucketOperator, S3DeleteBucketOperator
23+
from airflow.providers.amazon.aws.operators.s3 import S3CreateBucketOperator, S3DeleteBucketOperator
2424

2525
BUCKET_NAME = os.environ.get('BUCKET_NAME', 'test-airflow-12345')
2626

airflow/providers/amazon/aws/example_dags/example_s3_bucket_tagging.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,9 @@
1818
from datetime import datetime
1919

2020
from airflow.models.dag import DAG
21-
from airflow.providers.amazon.aws.operators.s3_bucket import S3CreateBucketOperator, S3DeleteBucketOperator
22-
from airflow.providers.amazon.aws.operators.s3_bucket_tagging import (
21+
from airflow.providers.amazon.aws.operators.s3 import (
22+
S3CreateBucketOperator,
23+
S3DeleteBucketOperator,
2324
S3DeleteBucketTaggingOperator,
2425
S3GetBucketTaggingOperator,
2526
S3PutBucketTaggingOperator,

airflow/providers/amazon/aws/example_dags/example_salesforce_to_s3.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,7 @@
2222
from datetime import datetime
2323

2424
from airflow import DAG
25-
from airflow.providers.amazon.aws.operators.s3_copy_object import S3CopyObjectOperator
26-
from airflow.providers.amazon.aws.operators.s3_delete_objects import S3DeleteObjectsOperator
25+
from airflow.providers.amazon.aws.operators.s3 import S3CopyObjectOperator, S3DeleteObjectsOperator
2726
from airflow.providers.amazon.aws.transfers.salesforce_to_s3 import SalesforceToS3Operator
2827

2928
BASE_PATH = "salesforce/customers"

0 commit comments

Comments
 (0)