Skip to content

Commit aeea712

Browse files
chipmyersjrchipmyersjr
authored
Remove args parameter from provider operator constructors (#10097)
1 parent 402e22c commit aeea712

File tree

97 files changed

+392
-644
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

97 files changed

+392
-644
lines changed

‎airflow/providers/amazon/aws/operators/athena.py‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,10 +59,9 @@ def __init__( # pylint: disable=too-many-arguments
5959
result_configuration=None,
6060
sleep_time=30,
6161
max_tries=None,
62-
*args,
6362
**kwargs
6463
):
65-
super().__init__(*args, **kwargs)
64+
super().__init__(**kwargs)
6665
self.query = query
6766
self.database = database
6867
self.output_location = output_location

‎airflow/providers/amazon/aws/operators/cloud_formation.py‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -49,8 +49,8 @@ def __init__(
4949
stack_name,
5050
params,
5151
aws_conn_id='aws_default',
52-
*args, **kwargs):
53-
super().__init__(*args, **kwargs)
52+
**kwargs):
53+
super().__init__(**kwargs)
5454
self.stack_name = stack_name
5555
self.params = params
5656
self.aws_conn_id = aws_conn_id
@@ -87,8 +87,8 @@ def __init__(
8787
stack_name,
8888
params=None,
8989
aws_conn_id='aws_default',
90-
*args, **kwargs):
91-
super().__init__(*args, **kwargs)
90+
**kwargs):
91+
super().__init__(**kwargs)
9292
self.params = params or {}
9393
self.stack_name = stack_name
9494
self.params = params

‎airflow/providers/amazon/aws/operators/datasync.py‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -121,10 +121,9 @@ def __init__(
121121
update_task_kwargs=None,
122122
task_execution_kwargs=None,
123123
delete_task_after_execution=False,
124-
*args,
125124
**kwargs
126125
):
127-
super().__init__(*args, **kwargs)
126+
super().__init__(**kwargs)
128127

129128
# Assignments
130129
self.aws_conn_id = aws_conn_id

‎airflow/providers/amazon/aws/operators/ec2_start_instance.py‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,9 +49,8 @@ def __init__(self,
4949
aws_conn_id: str = "aws_default",
5050
region_name: Optional[str] = None,
5151
check_interval: float = 15,
52-
*args,
5352
**kwargs):
54-
super().__init__(*args, **kwargs)
53+
super().__init__(**kwargs)
5554
self.instance_id = instance_id
5655
self.aws_conn_id = aws_conn_id
5756
self.region_name = region_name

‎airflow/providers/amazon/aws/operators/ec2_stop_instance.py‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,9 +49,8 @@ def __init__(self,
4949
aws_conn_id: str = "aws_default",
5050
region_name: Optional[str] = None,
5151
check_interval: float = 15,
52-
*args,
5352
**kwargs):
54-
super().__init__(*args, **kwargs)
53+
super().__init__(**kwargs)
5554
self.instance_id = instance_id
5655
self.aws_conn_id = aws_conn_id
5756
self.region_name = region_name

‎airflow/providers/amazon/aws/operators/emr_add_steps.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,12 +56,12 @@ def __init__(
5656
cluster_states=None,
5757
aws_conn_id='aws_default',
5858
steps=None,
59-
*args, **kwargs):
59+
**kwargs):
6060
if kwargs.get('xcom_push') is not None:
6161
raise AirflowException("'xcom_push' was deprecated, use 'do_xcom_push' instead")
6262
if not (job_flow_id is None) ^ (job_flow_name is None):
6363
raise AirflowException('Exactly one of job_flow_id or job_flow_name must be specified.')
64-
super().__init__(*args, **kwargs)
64+
super().__init__(**kwargs)
6565
steps = steps or []
6666
self.aws_conn_id = aws_conn_id
6767
self.job_flow_id = job_flow_id

‎airflow/providers/amazon/aws/operators/emr_create_job_flow.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,8 +48,8 @@ def __init__(
4848
emr_conn_id='emr_default',
4949
job_flow_overrides=None,
5050
region_name=None,
51-
*args, **kwargs):
52-
super().__init__(*args, **kwargs)
51+
**kwargs):
52+
super().__init__(**kwargs)
5353
self.aws_conn_id = aws_conn_id
5454
self.emr_conn_id = emr_conn_id
5555
if job_flow_overrides is None:

‎airflow/providers/amazon/aws/operators/emr_modify_cluster.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -43,10 +43,10 @@ def __init__(
4343
cluster_id: str,
4444
step_concurrency_level: int,
4545
aws_conn_id: str = 'aws_default',
46-
*args, **kwargs):
46+
**kwargs):
4747
if kwargs.get('xcom_push') is not None:
4848
raise AirflowException("'xcom_push' was deprecated, use 'do_xcom_push' instead")
49-
super().__init__(*args, **kwargs)
49+
super().__init__(**kwargs)
5050
self.aws_conn_id = aws_conn_id
5151
self.cluster_id = cluster_id
5252
self.step_concurrency_level = step_concurrency_level

‎airflow/providers/amazon/aws/operators/emr_terminate_job_flow.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,8 +39,8 @@ def __init__(
3939
self,
4040
job_flow_id,
4141
aws_conn_id='aws_default',
42-
*args, **kwargs):
43-
super().__init__(*args, **kwargs)
42+
**kwargs):
43+
super().__init__(**kwargs)
4444
self.job_flow_id = job_flow_id
4545
self.aws_conn_id = aws_conn_id
4646

‎airflow/providers/amazon/aws/operators/glue.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -69,9 +69,9 @@ def __init__(self,
6969
region_name=None,
7070
s3_bucket=None,
7171
iam_role_name=None,
72-
*args, **kwargs
72+
**kwargs
7373
): # pylint: disable=too-many-arguments
74-
super(AwsGlueJobOperator, self).__init__(*args, **kwargs)
74+
super(AwsGlueJobOperator, self).__init__(**kwargs)
7575
self.job_name = job_name
7676
self.job_desc = job_desc
7777
self.script_location = script_location

0 commit comments

Comments
 (0)