@@ -14,15 +14,13 @@ def __init__(self, environment: str, table_name: str, run_migration: bool = Fals
1414 self .environment = environment
1515 self .table_name = table_name
1616 self .run_migration = run_migration
17- self .target_table = f"{ self .environment } _ { self . table_name } "
17+ self .target_table = f"{ self .table_name } "
1818
1919 self .logger = LoggingService (self .__class__ .__name__ )
2020 self .dynamo_service = DynamoDBService ()
2121
2222 @abstractmethod
23- def main (
24- self , entries : Iterable [dict ]
25- ) -> list [tuple [str , Callable [[dict ], dict | None ]]]:
23+ def main (self , entries : Iterable [dict ]) -> list [tuple [str , Callable [[dict ], dict | None ]]]:
2624 pass
2725
2826 def process_entries (
@@ -46,9 +44,7 @@ def process_entries(
4644
4745 updated_fields = update_fn (entry )
4846 if not updated_fields :
49- self .logger .debug (
50- f"[{ label } ] Item { item_id } does not require update, skipping."
51- )
47+ self .logger .debug (f"[{ label } ] Item { item_id } does not require update, skipping." )
5248 continue
5349
5450 if self .run_migration :
@@ -62,8 +58,6 @@ def process_entries(
6258 except Exception as e :
6359 self .logger .error (f"[{ label } ] Failed to update item { item_id } : { str (e )} " )
6460 else :
65- self .logger .info (
66- f"[Dry Run] Would update item { item_id } with { updated_fields } "
67- )
61+ self .logger .info (f"[Dry Run] Would update item { item_id } with { updated_fields } " )
6862
6963 self .logger .info (f"'{ label } ' migration step completed.\n " )
0 commit comments