diff --git a/airflow_hop/operators.py b/airflow_hop/operators.py index 413168c..27c5d35 100644 --- a/airflow_hop/operators.py +++ b/airflow_hop/operators.py @@ -57,14 +57,14 @@ def __init__(self, log_level, *args, environment=None, - params=None, + hop_params=None, hop_conn_id='hop_default', **kwargs): super().__init__(*args, **kwargs) self.workflow = workflow self.project_name = project_name self.log_level = log_level - self.task_params = params + self.task_params = hop_params self.hop_conn_id = hop_conn_id self.environment = environment @@ -120,7 +120,7 @@ def __init__(self, log_level, *args, environment=None, - params=None, + hop_params=None, hop_conn_id='hop_default', **kwargs): super().__init__(*args, **kwargs) @@ -129,7 +129,7 @@ def __init__(self, self.project_name = project_name self.log_level = log_level self.hop_conn_id = hop_conn_id - self.task_params = params + self.task_params = hop_params self.environment = environment def __get_hop_client(self):