Remove unused parameters

WordPress · Aug 21, 2024 · 3413ead · 3413ead
1 parent c026c9e
commit 3413ead
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 8 deletions.
diff --git a/catalog/dags/data_refresh/copy_data.py b/catalog/dags/data_refresh/copy_data.py
@@ -198,7 +198,6 @@ def copy_data(
 def copy_upstream_table(
     upstream_conn_id: str,
     downstream_conn_id: str,
-    target_environment: Environment,
     timeout: timedelta,
     limit: int,
     upstream_table_name: str,
@@ -310,7 +309,6 @@ def copy_upstream_tables(
     copy_tables = copy_upstream_table.partial(
         upstream_conn_id=upstream_conn_id,
         downstream_conn_id=downstream_conn_id,
-        target_environment=target_environment,
         timeout=data_refresh_config.copy_data_timeout,
         limit=limit,
     ).expand_kwargs([asdict(tm) for tm in data_refresh_config.table_mappings])

diff --git a/catalog/dags/data_refresh/distributed_reindex.py b/catalog/dags/data_refresh/distributed_reindex.py
@@ -83,12 +83,10 @@ def response_check_wait_for_completion(response: Response) -> bool:
 
 
 @task
-@setup_ec2_hook
 def get_worker_params(
     estimated_record_count: int,
     environment: str,
     target_environment: Environment,
-    ec2_hook: EC2Hook = None,
 ):
     """Determine the set of start/end indices to be passed to each indexer worker."""
     # Defaults to one indexer worker in local development
@@ -232,8 +230,6 @@ def get_instance_ip_address(
     trigger_rule=TriggerRule.NONE_FAILED
 )
 def create_connection(
-    environment: str,
-    target_environment: str,
     instance_id: str,
     server: str,
 ):
@@ -313,8 +309,6 @@ def reindex(
     worker_conn = create_connection(
         instance_id=instance_id,
         server=instance_ip_address,
-        environment=environment,
-        target_environment=target_environment,
     )
 
     trigger_reindexing_task = TemplatedConnectionHttpOperator(